tidal / PEIP

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;