tidal / PEIP

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

src/INF/Dispatcher/ListDispatcher.php

Spacing +2 added lines, -2 removed lines

@@ -24,9 +24,9 @@
 
 interface ListDispatcher extends \PEIP\INF\Dispatcher\Dispatcher {
 
-    public function connect( $handler);
+    public function connect($handler);
 
-    public function disconnect( $handler);
+    public function disconnect($handler);
 
     public function hasListeners();
 

src/INF/Message/MessageDispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -26,11 +26,11 @@
 
     public function disconnect($name, \PEIP\INF\Message\MessageHandler $handler);
 
-    public function notify( $event);
+    public function notify($event);
 
-    public function notifyUntil( $event);
+    public function notifyUntil($event);
 
-    public function filter( $event, $value);
+    public function filter($event, $value);
 
     public function hasListeners($name);
 

src/Message/GenericMessage.php

Spacing +2 added lines, -2 removed lines

@@ -81,8 +81,8 @@
          * @access public
          * @return ArrayAccess ArrayAccess object of headers
          */
-    public function getHeaders(){
-        return (array) $this->headers;
+    public function getHeaders() {
+        return (array)$this->headers;
     }
   
     /**

Braces +2 added lines, -4 removed lines

@@ -134,12 +134,10 @@
         $res = false;
         try {
             $res = (string)$this->getContent();
-        }
-        catch (\Exception $e) {           
+        } catch (\Exception $e) {           
             try {
                 $res = get_class($this->getContent());
-            }
-            catch (\Exception $e) {
+            } catch (\Exception $e) {
                 return "";
             }
         }     

src/Message/CommandMessage.php

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     public function execute() {
         if (is_callable($this->getContent())) {
             return call_user_func($this->getContent());
-        }else {
+        } else {
             return $this->getContent()->execute();
         }
     }

src/Message/CallableMessageHandler.php

Braces +3 added lines, -4 removed lines

@@ -56,11 +56,11 @@ 
                 if ($static && !$reflectionFunc->isStatic()) {
                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  
                 }
-            }else {
+            } else {
                 $reflectionFunc = new \ReflectionFunction($this->callable);  
             }
             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();
-        }else {
+        } else {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');
         }   
     }   
@@ -79,8 +79,7 @@ 
         }   
         try {
             return call_user_func_array($this->callable, array($message, $channel, $sent));
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());
         }   
     }   

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