tidal / PEIP

src/Message/CommandMessage.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/ABS/Service/ServiceActivator.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/ABS/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/ABS/Dispatcher/Dispatcher.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.');
         }            
     }