tidal / PEIP

src/ABS/Splitter/MessageSplitter.php

Spacing +6 added lines, -6 removed lines

@@ -35,9 +35,9 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 
      * @return 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->setInputChannel($inputChannel);
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);    
         }   
     }           
@@ -49,13 +49,13 @@ 
      * @param \PEIP\INF\Message\Message $message message to split 
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){     
+    public function doReply(\PEIP\INF\Message\Message $message) {     
         $res = $this->split($message);      
-        if(is_array($res)){
-            foreach($res as $msg){ 
+        if (is_array($res)) {
+            foreach ($res as $msg) { 
                 $this->replyMessage($msg);
             }
-        }else{
+        }else {
             $this->replyMessage($res);
         }
     }

src/ABS/Dispatcher/MapDispatcher.php

Spacing +17 added lines, -17 removed lines

@@ -44,9 +44,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return 
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         Test::ensureHandler($listener);
-        if (!$this->hasListeners($name)){
+        if (!$this->hasListeners($name)) {
           $this->listeners[$name] = array();
         }
         $this->listeners[$name][] = $listener;
@@ -61,13 +61,13 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return 
      */
-    public function disconnect($name, $listener){
-        if (!$this->hasListeners($name)){
+    public function disconnect($name, $listener) {
+        if (!$this->hasListeners($name)) {
             return false;
         }
         $res = false;
-        foreach ($this->listeners[$name] as $i => $callable){
-          if ($listener === $callable){
+        foreach ($this->listeners[$name] as $i => $callable) {
+          if ($listener === $callable) {
             unset($this->listeners[$name][$i]);
             $res = true;
           }
@@ -83,8 +83,8 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return
      */
-    public function disconnectAll($name){
-        if (!isset($this->listeners[$name])){
+    public function disconnectAll($name) {
+        if (!isset($this->listeners[$name])) {
             return false;
         }
         $this->listeners[$name] = array();
@@ -98,11 +98,11 @@ 
      * @param string $name name of the event 
      * @return boolean wether any listener is registered for event-name
      */
-    public function hasListeners($name){
-        if (!isset($this->listeners[$name])){
+    public function hasListeners($name) {
+        if (!isset($this->listeners[$name])) {
             return false;
         }
-        return (boolean) count($this->listeners[$name]);
+        return (boolean)count($this->listeners[$name]);
     }
     
     /**
@@ -113,8 +113,8 @@ 
      * @param mixed $subject the subject 
      * @return boolean success
      */
-    public function notify($name, $subject){
-        if($this->hasListeners($name)){
+    public function notify($name, $subject) {
+        if ($this->hasListeners($name)) {
             self::doNotify($this->getListeners($name), $subject);
             return true;
         }
@@ -129,8 +129,8 @@ 
      * @param mixed $subject the subject 
      * @return \PEIP\INF\Handler\Handler listener which returned a boolean true value
      */
-    public function notifyUntil($name, $subject){
-        if($this->hasListeners($name)){
+    public function notifyUntil($name, $subject) {
+        if ($this->hasListeners($name)) {
             return self::doNotifyUntil($this->getListeners($name), $subject);   
         }
         return NULL;
@@ -143,8 +143,8 @@ 
      * @param $name 
      * @return array array of \PEIP\INF\Handler\Handler instances
      */
-    public function getListeners($name){
-        if (!isset($this->listeners[$name])){
+    public function getListeners($name) {
+        if (!isset($this->listeners[$name])) {
         return array();
         }
         return $this->listeners[$name];

src/ABS/Dispatcher/Dispatcher.php

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

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

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.');
         }            
     }       

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]);   
             }
         }