tidal / PEIP

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