tidal / PEIP

src/ABS/Service/ServiceActivator.php

Spacing +6 added lines, -6 removed lines

@@ -38,12 +38,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to handle/reply for
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){
+    public function doReply(\PEIP\INF\Message\Message $message) {
         $res = $this->callService($message);
         $out = (bool)$message->hasHeader('REPLY_CHANNEL') 
             ? $message->getHeader('REPLY_CHANNEL') 
             : $this->outputChannel;    
-        if($out){
+        if ($out) {
             $this->replyMessage($res, $res);    
         }
     }  
@@ -56,12 +56,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload
      * @return mixed result of calling the registered service callable with message content/payload
      */
-    protected function callService(\PEIP\INF\Message\Message $message){
+    protected function callService(\PEIP\INF\Message\Message $message) {
         $res = NULL;
-        if(is_callable($this->serviceCallable)){
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func($this->serviceCallable, $message->getContent());
-        }else{
-            if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }else {
+            if (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
                 $res = $this->serviceCallable->handle($message->getContent());
             }
         }    

src/ABS/Handler/ReplyProducingMessageHandler.php

Spacing +17 added lines, -17 removed lines

@@ -42,7 +42,7 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the output-channel
      * @return \PEIP\ABS\Handler\MessageHandler $this;
      */
-    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
+    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {
         $this->doSetOutputChannel($outputChannel);
         return $this;
     }   
@@ -54,7 +54,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the output-channel to connect the handler to
      * @return 
      */
-    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
+    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {
         $this->outputChannel = $outputChannel;
     }
        
@@ -64,7 +64,7 @@ 
      * @access public
      * @return \PEIP\INF\Channel\Channel output-channel for this handler
      */
-    public function getOutputChannel(){
+    public function getOutputChannel() {
         return $this->outputChannel;
     }
 
@@ -78,7 +78,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to resolve output-channel for
      * @return \PEIP\INF\Channel\Channel the output-channel for the message
      */    
-    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message){
+    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message) {
         $replyChannel = $this->resolveReplyChannel($message);
         return $replyChannel ? $replyChannel : $this->getOutputChannel();       
     }
@@ -92,9 +92,9 @@ 
      * @param \PEIP\INF\Message\Message $message 
      * @return \PEIP\INF\Channel\Channel the reply-channel if found
      */     
-    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message){
-        foreach($this->replyChannelHeaders as $header){
-            if($message->hasHeader($header)){
+    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message) {
+        foreach ($this->replyChannelHeaders as $header) {
+            if ($message->hasHeader($header)) {
                 return $message->getHeader($header);
             }
         }
@@ -111,7 +111,7 @@ 
      * @access protected
      * @param mixed $content \PEIP\INF\Message\Message or content/payload for new message 
      */
-    protected function replyMessage($content){
+    protected function replyMessage($content) {
         $message = $this->ensureMessage($content);      
         $this->doGetOutputChannel($message)->send($message);      
     }
@@ -125,7 +125,7 @@ 
      * @param mixed $message \PEIP\INF\Message\Message or content/payload for new message
      * @return \PEIP\INF\Message\Message
      */
-    protected function ensureMessage($message){
+    protected function ensureMessage($message) {
         return ($message instanceof \PEIP\INF\Message\Message) ? $message : $this->buildMessage($message);   
     }
        
@@ -138,7 +138,7 @@ 
      * @return \PEIP\INF\Message\Message
      * @see MessageBuilder
      */
-    protected function buildMessage($content){
+    protected function buildMessage($content) {
         return $this->getMessageBuilder()->setContent($content)->build();   
     }   
        
@@ -149,7 +149,7 @@ 
      * @access protected
      * @return MessageBuilder builder for the registered message class
      */
-    protected function getMessageBuilder(){
+    protected function getMessageBuilder() {
         return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())
             ? $this->messageBuilder
             : $this->messageBuilder = MessageBuilder::getInstance($this->messageClass);
@@ -162,7 +162,7 @@ 
      * @param string $messageClass name of the message-class to create reply-messages from. 
      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
      */
-    public function setMessageClass($messageClass){
+    public function setMessageClass($messageClass) {
         $this->messageClass = $messageClass;
         return $this;
     }
@@ -173,7 +173,7 @@ 
      * @access public
      * @return string name of the message-class to create reply-messages from. 
      */
-    public function getMessageClass(){
+    public function getMessageClass() {
         return $this->messageClass;
     }       
 
@@ -184,7 +184,7 @@ 
      * @param string $headerName name of a message-header to look for a reply-channel
      * @return void
      */
-    public function addReplyChannelHeader($headerName){
+    public function addReplyChannelHeader($headerName) {
         $this->replyChannelHeaders[] = $headerName;
     }
     
@@ -195,7 +195,7 @@ 
      * @param array $headerNames array of message-header names to look for a reply-channel
      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
      */
-    public function setReplyChannelHeaders(array $headerNames){
+    public function setReplyChannelHeaders(array $headerNames) {
         $this->replyChannelHeaders = $headerNames;
         return $this;
     } 
@@ -206,7 +206,7 @@ 
      * @access public
      * @return array array of message-header names to look for a reply-channel
      */
-    public function getReplyChannelHeaders(){
+    public function getReplyChannelHeaders() {
         return $this->replyChannelHeaders;
     }
          
@@ -220,7 +220,7 @@ 
      * @param \PEIP\INF\Message\Message $message 
      * @return 
      */
-    protected function doHandle(\PEIP\INF\Message\Message $message){
+    protected function doHandle(\PEIP\INF\Message\Message $message) {
         return $this->doReply($message);
     }
        

src/ABS/Handler/MessageHandler.php

Spacing +9 added lines, -9 removed lines

@@ -42,7 +42,7 @@ 
      * @param object $message the message to handle
      * @return 
      */
-    public function handle($message){
+    public function handle($message) {
          $this->doHandle($this->getMessageFromObject($message));      
     }
    
@@ -56,7 +56,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel
      * @return PEIP\ABS\Handler\MessageHandler $this;
      */
-    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){
+    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {
         $this->doSetInputChannel($inputChannel);
         return $this;
     }
@@ -73,24 +73,24 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel to connect the handler to
      * @return 
      */
-    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel){
+    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {
         $this->inputChannel = $inputChannel;    
-        if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){
+        if ($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel) {
                 $this->inputChannel->subscribe($this);
-        }else{          
+        }else {          
             $this->unwrapEvents = true;
             $this->inputChannel->connect('postSend', $this);
         }  
     }
   
-    protected function getMessageFromObject($object){ 
+    protected function getMessageFromObject($object) { 
         $content = $object->getContent();
-        if($this->unwrapEvents
+        if ($this->unwrapEvents
             && $object instanceof \PEIP\INF\Event\Event
             && $object->getName() == 'postSend'
             && $object->hasHeader(Pipe::HEADER_MESSAGE)
             && $content instanceof \PEIP\INF\Channel\PollableChannel
-         ){
+         ) {
             $object = $content->receive();
         }
         if (!($object instanceof \PEIP\INF\Message\Message)) {
@@ -106,7 +106,7 @@ 
      * @access public
      * @return \PEIP\INF\Channel\Channel input-channel for this handler
      */
-    public function getInputChannel(){
+    public function getInputChannel() {
         return $this->inputChannel;
     }   
       

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