tidal / PEIP

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/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/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);
             }
         //}

src/Gateway/SimpleMessagingGateway.php

Braces +1 added lines, -2 removed lines

@@ -115,8 +115,7 @@
         $this->send($content);
         try {
             $res = $this->receive();
-        }
-        catch(\Exception $e){
+        } catch(\Exception $e){
             return NULL;
         }
         return $res;

src/Service/ServiceProvider.php

Braces +5 added lines, -5 removed lines

@@ -118,7 +118,7 @@ 
 
         if($this->hasService($key)){
             $service =  $this->getService($key);
-        }else{
+        } else{
             $service =  $this->createService($key);
         }
 
@@ -150,11 +150,11 @@ 
                 ));
 
                 return $node;                
-            }else{
+            } else{
                 $errorMessage = 'COULD NOT BUILD NODE FOR KEY: '.$key;
             }
 
-        }else{
+        } else{
             $errorMessage = 'NO CONFIG FOR KEY: '.$key;
         }
         $this->doFireEvent(self::EVENT_CREATE_SERVICE_ERROR, array(
@@ -198,10 +198,10 @@ 
                     self::HEADER_NODE => $nodeInstance
                 ));
                 return $nodeInstance;
-            }else{
+            } else{
                 $errorMessage = 'BUILDER RETURNED NO OBJECT FOR NODE-TYPE: '.$nodeName;
             }
-        }else{
+        } else{
             $errorMessage = 'NO BUILDER FOUND FOR NODE-TYPE: '.$nodeName;
         }
 

src/Service/SplittingServiceActivator.php

Braces +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
     public function callService(\PEIP\INF\Message\Message $message){
         if(is_callable($this->serviceCallable)){
             $res = call_user_func_array($this->serviceCallable, $message->getContent());
-        }elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        } elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               
         }
         return $res;

src/Dispatcher/ObjectMapDispatcher.php

Braces +2 added lines, -2 removed lines

@@ -104,7 +104,7 @@ 
         $listners = $this->doGetListeners();
         if (!$this->hadListeners($name, $object)){
             $res = false;
-        }else{
+        } else{
             $listners = $this->doGetListeners();
             $res = (boolean) count($listners[$object][$name]);
         }
@@ -211,7 +211,7 @@ 
         foreach($listeners as $listener){ 
              if($listener instanceof \PEIP\INF\Handler\Handler){
                 $listener->handle($subject);
-             }elseif(is_callable($listener)){
+             } elseif(is_callable($listener)){
                  call_user_func($listener, $subject);
              }
         }   

src/Dispatcher/ObjectEventDispatcher.php

Braces +2 added lines, -2 removed lines

@@ -46,10 +46,10 @@
                 if($this->hasListeners($name, $object->getContent())){
                     return self::doNotify($this->getListeners($name, $object->getContent()), $object);  
                 }                   
-            }else{
+            } else{
                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
             }   
-        }else{
+        } else{
             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
         }  
     }   

src/Dispatcher/ClassDispatcher.php

Braces +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         $name = is_object($name) ? get_class($name) : (string)$name;
         if(Test::assertClassOrInterfaceExists($name)){
             parent::connect($name, $listener);
-        }else{
+        } else{
             throw new \InvalidArgumentException($name." is not an Class nor Interface");
         }
     }