tidal / PEIP

src/ABS/Channel/SubscribableChannel.php

Spacing +7 added lines, -7 removed lines

@@ -29,7 +29,7 @@ 
 

 abstract class SubscribableChannel 

     extends \PEIP\ABS\Channel\Channel

-    implements \PEIP\INF\Channel\SubscribableChannel{

+    implements \PEIP\INF\Channel\SubscribableChannel {

 

     protected $messageDispatcher;   

        

@@ -41,7 +41,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to subscribe

      * @return 

      */

-    public function subscribe($handler){ 

+    public function subscribe($handler) { 

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->connect($handler);

         $this->doFireEvent('subscribe', array('SUBSCRIBER'=>$handler));

@@ -55,7 +55,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to unsubscribe

      * @return 

      */

-    public function unsubscribe($handler){

+    public function unsubscribe($handler) {

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->disconnect($handler);

         $this->doFireEvent('unsubscribe', array('SUBSCRIBER'=>$handler));       

@@ -69,9 +69,9 @@ 
      * @param boolean $transferListeners wether to transfer listeners of old dispatcher (if set) to new one. default: true 

      * @return 

      */

-    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true){

-        if(isset($this->dispatcher) && $transferListeners){

-            foreach($this->dispatcher->getListeners() as $listener){

+    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true) {

+        if (isset($this->dispatcher) && $transferListeners) {

+            foreach ($this->dispatcher->getListeners() as $listener) {

                 $dispatcher->connect($listener);

                 $this->dispatcher->disconnect($listener);       

             }   

@@ -85,7 +85,7 @@ 
      * @access public

      * @return 

      */

-    public function getMessageDispatcher(){

+    public function getMessageDispatcher() {

         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new Dispatcher;

     }   

     

src/ABS/Channel/Channel.php

Spacing +3 added lines, -3 removed lines

@@ -34,7 +34,7 @@ 
      * @param $name

      * @return

      */

-    public function __construct($name){

+    public function __construct($name) {

         $this->name = $name;

     }

 

@@ -42,7 +42,7 @@ 
      * @access public

      * @return string the channel�s name

      */

-    public function getName(){

+    public function getName() {

         return $this->name;

     }

 

@@ -52,7 +52,7 @@ 
      * @param integer $timeout

      * @return

      */

-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){

+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {

         $this->doFireEvent('preSend', array('MESSAGE'=>$message));

         $sent = $this->doSend($message);

         $this->doFireEvent('postSend', array(

src/ABS/Command/Command.php

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
      * @access public

      * @return 

      */

-    public function __invoke(){

+    public function __invoke() {

         return $this->execute();

     }

    

@@ -51,7 +51,7 @@ 
      * @access public

      * @return 

      */

-    public function execute(){

+    public function execute() {

         return call_user_func_array($this->callable, $this->getParameters());

     }   

         

src/ABS/Context/ContextPlugin.php

Spacing +3 added lines, -3 removed lines

@@ -40,9 +40,9 @@ 
      * @param \PEIP\INF\Context\Context $context context instance to register the plugin with

      * @return 

      */

-    public function init(\PEIP\INF\Context\Context $context){

+    public function init(\PEIP\INF\Context\Context $context) {

         $this->context = $context;

-        foreach($this->builders as $node=>$method){

+        foreach ($this->builders as $node=>$method) {

             $context->registerNodeBuilder($node, array($this, $method));        

         }   

     }

@@ -59,7 +59,7 @@ 
      * @param string $defaultClass class to create instance for if none is set in config

      * @return object build and modified srvice instance

      */

-    public function buildAndModify($config, $arguments, $defaultClass = false){

+    public function buildAndModify($config, $arguments, $defaultClass = false) {

         return ServiceFactory::buildAndModify($config, $arguments, $defaultClass);

     }

 }

src/ABS/Request/Request.php

Spacing +4 added lines, -4 removed lines

@@ -37,7 +37,7 @@ 
      * @param $connection 

      * @return 

      */

-    public function setConnection($connection){

+    public function setConnection($connection) {

         $this->connection = $connection;

     }

     

@@ -47,7 +47,7 @@ 
      * @access public

      * @return 

      */

-    public function execute(){

+    public function execute() {

         return $this->send();   

     }

 

@@ -56,7 +56,7 @@ 
      * @access public

      * @return 

      */

-    public function send(){

+    public function send() {

         return $this->connection->sendRequest($this);

     }

     

@@ -65,7 +65,7 @@ 
      * @access public

      * @return 

      */

-    public function getRequestData(){

+    public function getRequestData() {

         return $this->doGetRequestData();   

     }

     

src/ABS/Request/Connection.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param $request 

      * @return 

      */

-    public function sendRequest(\PEIP\ABS\Request\Request $request){

+    public function sendRequest(\PEIP\ABS\Request\Request $request) {

         return $this->doSendRequest($request);

     }

     

src/ABS/Handler/MessageHandler.php

Spacing +9 added lines, -9 removed lines

@@ -42,7 +42,7 @@ 
      * @param object $message the message to handle

      * @return 

      */

-    public function handle($message){

+    public function handle($message) {

          $this->doHandle($this->getMessageFromObject($message));      

     }

    

@@ -56,7 +56,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel

      * @return PEIP\ABS\Handler\MessageHandler $this;

      */

-    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){

+    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {

         $this->doSetInputChannel($inputChannel);

         return $this;

     }

@@ -73,24 +73,24 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel to connect the handler to

      * @return 

      */

-    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel){

+    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {

         $this->inputChannel = $inputChannel;    

-        if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){

+        if ($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel) {

                 $this->inputChannel->subscribe($this);

-        }else{          

+        }else {          

             $this->unwrapEvents = true;

             $this->inputChannel->connect('postSend', $this);

         }  

     }

   

-    protected function getMessageFromObject($object){ 

+    protected function getMessageFromObject($object) { 

         $content = $object->getContent();

-        if($this->unwrapEvents

+        if ($this->unwrapEvents

             && $object instanceof \PEIP\INF\Event\Event

             && $object->getName() == 'postSend'

             && $object->hasHeader(Pipe::HEADER_MESSAGE)

             && $content instanceof \PEIP\INF\Channel\PollableChannel

-         ){

+         ) {

             $object = $content->receive();

         }

         if (!($object instanceof \PEIP\INF\Message\Message)) {

@@ -106,7 +106,7 @@ 
      * @access public

      * @return \PEIP\INF\Channel\Channel input-channel for this handler

      */

-    public function getInputChannel(){

+    public function getInputChannel() {

         return $this->inputChannel;

     }   

       

src/ABS/Handler/ReplyProducingMessageHandler.php

Spacing +17 added lines, -17 removed lines

@@ -44,7 +44,7 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the output-channel

      * @return \PEIP\ABS\Handler\MessageHandler $this;

      */

-    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){

+    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {

         $this->doSetOutputChannel($outputChannel);

         return $this;

     }   

@@ -56,7 +56,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the output-channel to connect the handler to

      * @return 

      */

-    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){

+    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {

         $this->outputChannel = $outputChannel;

     }

        

@@ -66,7 +66,7 @@ 
      * @access public

      * @return \PEIP\INF\Channel\Channel output-channel for this handler

      */

-    public function getOutputChannel(){

+    public function getOutputChannel() {

         return $this->outputChannel;

     }

 

@@ -80,7 +80,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to resolve output-channel for

      * @return \PEIP\INF\Channel\Channel the output-channel for the message

      */    

-    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message){

+    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message) {

         $replyChannel = $this->resolveReplyChannel($message);

         return $replyChannel ? $replyChannel : $this->getOutputChannel();       

     }

@@ -94,9 +94,9 @@ 
      * @param \PEIP\INF\Message\Message $message 

      * @return \PEIP\INF\Channel\Channel the reply-channel if found

      */     

-    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message){

-        foreach($this->replyChannelHeaders as $header){

-            if($message->hasHeader($header)){

+    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message) {

+        foreach ($this->replyChannelHeaders as $header) {

+            if ($message->hasHeader($header)) {

                 return $message->getHeader($header);

             }

         }

@@ -113,7 +113,7 @@ 
      * @access protected

      * @param mixed $content \PEIP\INF\Message\Message or content/payload for new message 

      */

-    protected function replyMessage($content){

+    protected function replyMessage($content) {

         $message = $this->ensureMessage($content);      

         $this->doGetOutputChannel($message)->send($message);      

     }

@@ -127,7 +127,7 @@ 
      * @param mixed $message \PEIP\INF\Message\Message or content/payload for new message

      * @return \PEIP\INF\Message\Message

      */

-    protected function ensureMessage($message){

+    protected function ensureMessage($message) {

         return ($message instanceof \PEIP\INF\Message\Message) ? $message : $this->buildMessage($message);   

     }

        

@@ -140,7 +140,7 @@ 
      * @return \PEIP\INF\Message\Message

      * @see MessageBuilder

      */

-    protected function buildMessage($content){

+    protected function buildMessage($content) {

         return $this->getMessageBuilder()->setContent($content)->build();   

     }   

        

@@ -151,7 +151,7 @@ 
      * @access protected

      * @return MessageBuilder builder for the registered message class

      */

-    protected function getMessageBuilder(){

+    protected function getMessageBuilder() {

         return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())

             ? $this->messageBuilder

             : $this->messageBuilder = MessageBuilder::getInstance($this->messageClass);

@@ -164,7 +164,7 @@ 
      * @param string $messageClass name of the message-class to create reply-messages from. 

      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this

      */

-    public function setMessageClass($messageClass){

+    public function setMessageClass($messageClass) {

         $this->messageClass = $messageClass;

         return $this;

     }

@@ -175,7 +175,7 @@ 
      * @access public

      * @return string name of the message-class to create reply-messages from. 

      */

-    public function getMessageClass(){

+    public function getMessageClass() {

         return $this->messageClass;

     }       

 

@@ -186,7 +186,7 @@ 
      * @param string $headerName name of a message-header to look for a reply-channel

      * @return void

      */

-    public function addReplyChannelHeader($headerName){

+    public function addReplyChannelHeader($headerName) {

         $this->replyChannelHeaders[] = $headerName;

     }

     

@@ -197,7 +197,7 @@ 
      * @param array $headerNames array of message-header names to look for a reply-channel

      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this

      */

-    public function setReplyChannelHeaders(array $headerNames){

+    public function setReplyChannelHeaders(array $headerNames) {

         $this->replyChannelHeaders = $headerNames;

         return $this;

     } 

@@ -208,7 +208,7 @@ 
      * @access public

      * @return array array of message-header names to look for a reply-channel

      */

-    public function getReplyChannelHeaders(){

+    public function getReplyChannelHeaders() {

         return $this->replyChannelHeaders;

     }

          

@@ -222,7 +222,7 @@ 
      * @param \PEIP\INF\Message\Message $message 

      * @return 

      */

-    protected function doHandle(\PEIP\INF\Message\Message $message){

+    protected function doHandle(\PEIP\INF\Message\Message $message) {

         return $this->doReply($message);

     }

        

src/ABS/Splitter/MessageSplitter.php

Spacing +6 added lines, -6 removed lines

@@ -35,9 +35,9 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 

      * @return 

      */

-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){

+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {

         $this->setInputChannel($inputChannel);

-        if(is_object($outputChannel)){

+        if (is_object($outputChannel)) {

             $this->setOutputChannel($outputChannel);    

         }   

     }           

@@ -49,13 +49,13 @@ 
      * @param \PEIP\INF\Message\Message $message message to split 

      * @return 

      */

-    public function doReply(\PEIP\INF\Message\Message $message){     

+    public function doReply(\PEIP\INF\Message\Message $message) {     

         $res = $this->split($message);      

-        if(is_array($res)){

-            foreach($res as $msg){ 

+        if (is_array($res)) {

+            foreach ($res as $msg) { 

                 $this->replyMessage($msg);

             }

-        }else{

+        }else {

             $this->replyMessage($res);

         }

     }