tidal / PEIP

src/ABS/Dispatcher/Dispatcher.php

Indentation +2 added lines, -2 removed lines

@@ -60,9 +60,9 @@
      */     
     protected static function doNotifyUntil(array $listeners, $subject){
         foreach ($listeners as $listener){
-          if (self::doNotifyOne($listener, $subject)){
+            if (self::doNotifyOne($listener, $subject)){
             return $listener;
-          }
+            }
         }
         return NULL;
     } 

Spacing +8 added lines, -8 removed lines

@@ -33,16 +33,16 @@ 
      * @param mixed $subject subject to notify the listeners of 
      * @return void
      */ 
-    protected static function doNotify(array $listeners, $subject){
-        foreach($listeners as $listener){
+    protected static function doNotify(array $listeners, $subject) {
+        foreach ($listeners as $listener) {
             self::doNotifyOne($listener, $subject);
         }   
     }  
 
-    protected static function doNotifyOne($listener, $subject){
-        if(is_callable($listener)){
+    protected static function doNotifyOne($listener, $subject) {
+        if (is_callable($listener)) {
             $res = call_user_func($listener, $subject);
-        }else{
+        }else {
             $res = $listener->handle($subject);
         }
         return $res;
@@ -58,9 +58,9 @@ 
      * @param mixed $subject subject to notify the listeners of 
      * @return \PEIP\INF\Handler\Handler listener that returned a boolean true value
      */     
-    protected static function doNotifyUntil(array $listeners, $subject){
-        foreach ($listeners as $listener){
-          if (self::doNotifyOne($listener, $subject)){
+    protected static function doNotifyUntil(array $listeners, $subject) {
+        foreach ($listeners as $listener) {
+          if (self::doNotifyOne($listener, $subject)) {
             return $listener;
           }
         }

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/Channel/ChannelAdapter.php

Spacing +6 added lines, -6 removed lines

@@ -9,22 +9,22 @@
     protected $channel;
     protected $handler;
 
-    public function __construct(\PEIP\ABS\Handler\MessageHandler $handler,  $channel){
+    public function __construct(\PEIP\ABS\Handler\MessageHandler $handler, $channel) {
         $this->channel = $channel;
         $this->handler = $handler;
     }
 
-    protected function getMessage($object){
-        if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){
+    protected function getMessage($object) {
+        if ($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel) {
             return $object; 
-        }else{
+        }else {
             return $object->getContent()->receive();
         }
     }
 
-    public function handle($object){
+    public function handle($object) {
         $message = $this->getMessage($object);
-                if(!is_object($message)){ 
+                if (!is_object($message)) { 
                     throw new \Exception('Could not get Message from Channel');
                 }               
                 $this->handler->handle($message);

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/Channel/ChannelRegistry.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param $name 
      * @return 
      */
-    public static function getInstance(){
+    public static function getInstance() {
         return self::$instance ? self::$instance : self::$instance = new ChannelRegistry;
     }
     
@@ -43,7 +43,7 @@ 
      * @param $channel 
      * @return 
      */
-    public function register($channel){
+    public function register($channel) {
         $this->channels[$channel->getName()] = $channel;
     }
 
@@ -55,7 +55,7 @@ 
      * @param $name 
      * @return 
      */
-    public function get($name){
+    public function get($name) {
         return $this->channels[$name];
     }
 
@@ -65,7 +65,7 @@ 
      * @param $channelName 
      * @return 
      */
-    public function resolveChannelName($channelName){
+    public function resolveChannelName($channelName) {
         return $this->get($channelName);
     }   
     

src/Channel/PublishSubscribeChannel.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->doFireEvent('prePublish', array('MESSAGE'=>$message));
         $this->getMessageDispatcher()->notify($message);
         $this->doFireEvent('postPublish', array('MESSAGE'=>$message));

src/Channel/DirectChannel.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
      * @param $timeout 
      * @return boolean wether message was sent successfully
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         return $this->doSend($message);
     }       
         
@@ -47,7 +47,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->getMessageDispatcher()->notify($message);
         return true;
     }
@@ -57,7 +57,7 @@ 
      * @access public
      * @return 
      */
-    public function getMessageDispatcher(){
+    public function getMessageDispatcher() {
         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new IteratingDispatcher;
     }   
     

src/Channel/QueueChannel.php

Spacing +7 added lines, -7 removed lines

@@ -37,7 +37,7 @@ 
      * @param $capacity 
      * @return 
      */
-    public function __construct($capacity = -1){
+    public function __construct($capacity = -1) {
         $this->setCapacity((int)$capacity);
         $this->queue = new SplQueue();  
     }   
@@ -47,7 +47,7 @@ 
      * @access public
      * @return 
      */
-    public function getMessageCount(){
+    public function getMessageCount() {
         return count($this->messages);
     }   
 
@@ -56,7 +56,7 @@ 
      * @access public
      * @return 
      */
-    public function getCapacity(){
+    public function getCapacity() {
         return $this->capacity;
     }       
 
@@ -66,7 +66,7 @@ 
      * @param $capacity 
      * @return 
      */
-    public function setCapacity($capacity){
+    public function setCapacity($capacity) {
         $this->capacity = $capacity;
     }   
 
@@ -76,10 +76,10 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
+        if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->enqueque($message);
-        }else{
+        }else {
             throw new \Exception('Not implemented yet.');
         }            
     }       

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/Channel/PollableChannel.php

Spacing +12 added lines, -12 removed lines

@@ -41,7 +41,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to send
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->messages[] = $message;
         return true;
     }
@@ -55,18 +55,18 @@ 
      * @param integer $timeout timout for receiving a message 
      * @return 
      */
-    public function receive($timeout = 0){
+    public function receive($timeout = 0) {
         $this->doFireEvent(self::EVENT_PRE_RECEIVE);
         $message = NULL;
-        if($timeout == 0){
+        if ($timeout == 0) {
             $message = $this->getMessage(); 
-        }elseif($timeout < 0){
-            while(!$message = $this->getMessage()){
+        }elseif ($timeout < 0) {
+            while (!$message = $this->getMessage()) {
                                 
             }
-        }else{
+        }else {
             $time = time() + $timeout;
-            while(($time > time()) && !$message = $this->getMessage()){
+            while (($time > time()) && !$message = $this->getMessage()) {
                 
             }       
         }
@@ -84,7 +84,7 @@ 
      * @access protected
      * @return \PEIP\INF\Message\Message message from top of the message stack
      */
-    protected function getMessage(){
+    protected function getMessage() {
         return array_shift($this->messages);
     }
        
@@ -94,7 +94,7 @@ 
      * @access public
      * @return 
      */
-    public function clear(){
+    public function clear() {
         $this->messages = array();
     }
         
@@ -105,9 +105,9 @@ 
      * @param \PEIP\INF\Message\Message_Selector $selector the selector to accept messages 
      * @return array accepted messages
      */
-    public function purge(\PEIP\INF\Selector\MessageSelector $selector){
-        foreach($this->messages as $key=>$message){
-            if(!$selector->acceptMessage($message)){
+    public function purge(\PEIP\INF\Selector\MessageSelector $selector) {
+        foreach ($this->messages as $key=>$message) {
+            if (!$selector->acceptMessage($message)) {
                 unset($this->messages[$key]);   
             }
         }

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

Spacing +5 added lines, -5 removed lines

@@ -37,10 +37,10 @@ 
      * @param $priorityHeader 
      * @return 
      */
-    public function __construct($capacity = -1, $priorityHeader = NULL){
+    public function __construct($capacity = -1, $priorityHeader = NULL) {
         $this->setCapacity((int)$capacity);
         $this->queue = new SplPriorityQueue(); 
-        if($priorityHeader){
+        if ($priorityHeader) {
             $this->priorityHeader = $priorityHeader;
         }
     }   
@@ -51,10 +51,10 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
-        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
+    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.');
         }            
     }       

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/Channel/MessageChannel.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
      * @access public
      * @return 
      */
-    public function getName(){
+    public function getName() {
     
     }
 
@@ -40,7 +40,7 @@ 
      * @param $timeout 
      * @return 
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         
     }