tidal / PEIP

src/ABS/Service/ServiceActivator.php

Braces +1 added lines, -1 removed lines

@@ -60,7 +60,7 @@
         $res = NULL;
         if(is_callable($this->serviceCallable)){
             $res = call_user_func($this->serviceCallable, $message->getContent());
-        }else{
+        } else{
             if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
                 $res = $this->serviceCallable->handle($message->getContent());
             }

src/ABS/Handler/MessageHandler.php

Braces +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
         $this->inputChannel = $inputChannel;    
         if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){
                 $this->inputChannel->subscribe($this);
-        }else{          
+        } else{          
             $this->unwrapEvents = true;
             $this->inputChannel->connect('postSend', $this);
         }  

src/ABS/Splitter/MessageSplitter.php

Braces +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
             foreach($res as $msg){ 
                 $this->replyMessage($msg);
             }
-        }else{
+        } else{
             $this->replyMessage($res);
         }
     }

src/ABS/Dispatcher/Dispatcher.php

Braces +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
     protected static function doNotifyOne($listener, $subject){
         if(is_callable($listener)){
             $res = call_user_func($listener, $subject);
-        }else{
+        } else{
             $res = $listener->handle($subject);
         }
         return $res;

src/Channel/ChannelAdapter.php

Braces +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     protected function getMessage($object){
         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){
             return $object; 
-        }else{
+        } else{
             return $object->getContent()->receive();
         }
     }

src/Channel/QueueChannel.php

Braces +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
     protected function doSend(\PEIP\INF\Message\Message $message){
         if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
             $this->queue->enqueque($message);
-        }else{
+        } else{
             throw new \Exception('Not implemented yet.');
         }            
     }       

src/Channel/PollableChannel.php

Braces +2 added lines, -2 removed lines

@@ -60,11 +60,11 @@
         $message = NULL;
         if($timeout == 0){
             $message = $this->getMessage(); 
-        }elseif($timeout < 0){
+        } elseif($timeout < 0){
             while(!$message = $this->getMessage()){
                                 
             }
-        }else{
+        } else{
             $time = time() + $timeout;
             while(($time > time()) && !$message = $this->getMessage()){
                 

src/Channel/PriorityChannel.php

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     protected function doSend(\PEIP\INF\Message\Message $message){
         if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
             $this->queue->insert($message, $message->getHeader($this->priorityHeader));
-        }else{
+        } else{
             throw new \Exception('Not implemented yet.');
         }            
     }       

src/Pipe/Pipe.php

Braces +1 added lines, -1 removed lines

@@ -108,7 +108,7 @@
         //if(\PEIP\Util\Test::assertMessage($message)){
             if($this->getOutputChannel()){ 
                 $this->getOutputChannel()->send($message);
-            }else{ 
+            } else{ 
                 $this->doSend($message);
             }
         //}