tidal / PEIP

src/ABS/Handler/MessageHandler.php

Spacing +7 added lines, -7 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));      
     }
    
@@ -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)) {

src/Data/StoreCollection.php

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
             $store = $this->factory->build();
             if ($store instanceof \PEIP\INF\Data\Store) {
                 $this->setPrivateValue($namespace, $store);
-            }else {
+            } else {
                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');
             }
         }

src/Translator/XMLArrayTranslator.php

Braces +2 added lines, -3 removed lines

@@ -30,8 +30,7 @@ 
                 throw new \Exception('loading XML failed');  
             }
             
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             return false;
         }     
         
@@ -65,7 +64,7 @@ 
                         )
                     );
                 }
-            }else {
+            } else {
                 $array[$name] = array();
             }
             $array[$name][] = $res;

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/Event/Observable.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
          * @param $observer 
          * @return 
          */
-    public function addObserver(\PEIP\INF\Event\Observer $observer){
+    public function addObserver(\PEIP\INF\Event\Observer $observer) {
         $this->observers[] = $observer;     
     }
 

src/Gateway/SimpleMessagingGateway.php

Braces +1 added lines, -2 removed lines

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

src/Pipe/FixedEventPipe.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/Data/ParameterHolderCollection.php

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
             $store = $this->factory->build();
             if ($store instanceof \PEIP\INF\Data\Store) {
                 $this->setPrivateValue($namespace, $store);
-            }else {
+            } else {
                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');
             }
         }