tidal / PEIP

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/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/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) {

         

     }

 

src/Channel/DirectChannel.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
      * @param $timeout 

      * @return 

      */

-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){

+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {

 

         $sent = $this->doSend($message);

 

@@ -49,7 +49,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;

     }

@@ -59,7 +59,7 @@ 
      * @access public

      * @return 

      */

-    public function getMessageDispatcher(){

+    public function getMessageDispatcher() {

         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new IteratingDispatcher;

     }   

     

src/Channel/PublishSubscribeChannel.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,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/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

@@ -17,7 +17,7 @@
     protected function getMessage($object){

         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }

src/Command/Command.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param $params 

      * @return 

      */

-    public function __construct($callable, array $params = array()){

+    public function __construct($callable, array $params = array()) {

         $this->callable = $callable;

         $this->setParameters($params);

     }

src/Data/Store.php

Spacing +7 added lines, -7 removed lines

@@ -34,7 +34,7 @@ 
      * @param mixed $value the value to store

      * @return 

      */

-    public function setValue($key, $value){

+    public function setValue($key, $value) {

         return $this->offsetSet($key, $value);

     }

     

@@ -45,7 +45,7 @@ 
      * @param mixed $key the key to return value for 

      * @return mixed the value for the given key

      */

-    public function getValue($key){

+    public function getValue($key) {

         return $this->offsetGet($key, $value);

     }

   

@@ -56,7 +56,7 @@ 
      * @param mixed $key the key to unset value for 

      * @return 

      */

-    public function deleteValue($key){

+    public function deleteValue($key) {

         return $this->offsetUnset($key);

     }

       

@@ -67,7 +67,7 @@ 
      * @param mixed $key the key to look for a value

      * @return boolean wether a value is stored for the key

      */

-    public function hasValue($key){

+    public function hasValue($key) {

         return $this->offsetExists($key);

     }   

 

@@ -78,7 +78,7 @@ 
      * @param array $values key/value pairs to store

      * @return 

      */

-    public function setValues(array $values){

+    public function setValues(array $values) {

         $this->values = $values;        

     }

 

@@ -88,7 +88,7 @@ 
      * @access public

      * @return array stored key/value pairs

      */

-    public function getValues(){

+    public function getValues() {

         return $this->values;

     }

    

@@ -100,7 +100,7 @@ 
      * @param $values 

      * @return 

      */

-    public function addValues(array $values){

+    public function addValues(array $values) {

         array_merge($this->values, $values);

     }   

 }
\ No newline at end of file

src/Data/ParameterHolderCollection.php

Indentation +11 added lines, -11 removed lines

@@ -74,7 +74,7 @@ 
      */

     public function setParameters($namespace, array $parameters){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

   

   

     /**

@@ -85,7 +85,7 @@ 
      */

     public function addParameters($namespace, array $parameters){

         $this->getParameterHolderOrCreate($namespace)->addParameters($parameters);

-   }

+    }

   

   

     /**

@@ -102,7 +102,7 @@ 
      */

     public function getParameters($namespace){

         $this->getParameterHolderOrCreate($namespace)->getParameters();

-   }

+    }

   

   

     /**

@@ -113,7 +113,7 @@ 
      */

     public function getParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->getParameter($name);

-   }

+    }

   

   

     /**

@@ -125,7 +125,7 @@ 
      */

     public function setParameter($namespace, $name, $value){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

   

   

     /**

@@ -136,7 +136,7 @@ 
      */

     public function hasParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->hasParameter($name);

-   }

+    }

 

   

     /**

@@ -147,7 +147,7 @@ 
      */

     public function deleteParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

 

   

     /**

@@ -166,7 +166,7 @@ 
      */

     public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder){

     $this->stores[$namespace] = $holder;

-  } 

+    } 

 

   

     /**

@@ -183,7 +183,7 @@ 
      */

     public function getParameterHolder($namespace){

     return $this->stores[$namespace];

-  }

+    }

 

   

     /**

@@ -200,7 +200,7 @@ 
      */

     public function hasParameterHolder($namespace){

     return array_key_exists($namespace, $this->stores);

-  }

+    }

 

   

     /**

@@ -217,7 +217,7 @@ 
      */

     public function deleteParameterHolder($namespace){

     unset($this->stores[$namespace]);

-  } 

+    } 

     

     

 

Spacing +16 added lines, -16 removed lines

@@ -35,7 +35,7 @@ 
      * @param $factory 

      * @return 

      */

-    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory){

+    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory) {

         $this->factory = $factory;

     }

 

@@ -45,12 +45,12 @@ 
      * @param $namespace 

      * @return 

      */

-    protected function getParameterHolderOrCreate($namespace){

-        if(!$this->hasParameterHolder($namespace)){

+    protected function getParameterHolderOrCreate($namespace) {

+        if (!$this->hasParameterHolder($namespace)) {

             $store = $this->factory->build();

-            if($store instanceof \PEIP\INF\Data\ParameterHolder){

+            if ($store instanceof \PEIP\INF\Data\ParameterHolder) {

                 $this->stores[$namespace] = $store;

-            }else{

+            }else {

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\ParameterHolder from factory.');

             }

         }

@@ -72,7 +72,7 @@ 
      * @param $value 

      * @return 

      */

-    public function setParameters($namespace, array $parameters){

+    public function setParameters($namespace, array $parameters) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

   

@@ -83,7 +83,7 @@ 
      * @param $parameters 

      * @return 

      */

-    public function addParameters($namespace, array $parameters){

+    public function addParameters($namespace, array $parameters) {

         $this->getParameterHolderOrCreate($namespace)->addParameters($parameters);

    }

   

@@ -100,7 +100,7 @@ 
      * @param $name 

      * @return 

      */

-    public function getParameters($namespace){

+    public function getParameters($namespace) {

         $this->getParameterHolderOrCreate($namespace)->getParameters();

    }

   

@@ -111,7 +111,7 @@ 
      * @param $name 

      * @return 

      */

-    public function getParameter($namespace, $name){

+    public function getParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->getParameter($name);

    }

   

@@ -123,7 +123,7 @@ 
      * @param $value 

      * @return 

      */

-    public function setParameter($namespace, $name, $value){

+    public function setParameter($namespace, $name, $value) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

   

@@ -134,7 +134,7 @@ 
      * @param $name 

      * @return 

      */

-    public function hasParameter($namespace, $name){

+    public function hasParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->hasParameter($name);

    }

 

@@ -145,7 +145,7 @@ 
      * @param $name 

      * @return 

      */

-    public function deleteParameter($namespace, $name){

+    public function deleteParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

 

@@ -164,7 +164,7 @@ 
      * @param $holder 

      * @return 

      */

-    public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder){

+    public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder) {

     $this->stores[$namespace] = $holder;

   } 

 

@@ -181,7 +181,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function getParameterHolder($namespace){

+    public function getParameterHolder($namespace) {

     return $this->stores[$namespace];

   }

 

@@ -198,7 +198,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function hasParameterHolder($namespace){

+    public function hasParameterHolder($namespace) {

     return array_key_exists($namespace, $this->stores);

   }

 

@@ -215,7 +215,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function deleteParameterHolder($namespace){

+    public function deleteParameterHolder($namespace) {

     unset($this->stores[$namespace]);

   } 

     

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
             $store = $this->factory->build();

             if($store instanceof \PEIP\INF\Data\Store){

                 $this->setPrivateValue($namespace, $store);

-            }else{

+            } else{

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');

             }

         }