tidal / PEIP

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

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

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

   } 

     

src/Data/InternalStoreAbstract.php

Spacing +7 added lines, -7 removed lines

@@ -32,7 +32,7 @@ 
      * @param $key 

      * @return 

      */

-    protected function hasInternalValue($key){

+    protected function hasInternalValue($key) {

         return array_key_exists($key, $this->internalValues);

     }   

     

@@ -42,7 +42,7 @@ 
      * @param $key 

      * @return 

      */

-    protected function getInternalValue($key){

+    protected function getInternalValue($key) {

         return array_key_exists($key, $this->internalValues) ? $this->internalValues[$key] : NULL;

     }

     

@@ -52,7 +52,7 @@ 
      * @param $key 

      * @return 

      */

-    protected function deleteInternalValue($key){

+    protected function deleteInternalValue($key) {

         unset($this->internalValues[$offset]);

     }   

 

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

      * @return 

      */

-    protected function setInternalValue($key, $value){

+    protected function setInternalValue($key, $value) {

         $this->internalValues[$key] = $value;

     }

     

@@ -80,7 +80,7 @@ 
      * @param $internalValues 

      * @return 

      */

-    protected function setInternalValues(array $internalValues){

+    protected function setInternalValues(array $internalValues) {

         $this->internalValues = $internalValues;        

     }

 

@@ -95,7 +95,7 @@ 
      * @access protected

      * @return 

      */

-    protected function getInternalValues(){

+    protected function getInternalValues() {

         return $this->internalValues;

     }

 

@@ -104,7 +104,7 @@ 
      * @access protected

      * @return 

      */

-    protected function addInternalValues(){

+    protected function addInternalValues() {

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

     }   

     

src/Data/ParameterCollection.php

Spacing +4 added lines, -4 removed lines

@@ -32,7 +32,7 @@ 
      * @param $offset 

      * @return 

      */

-    public function offsetExists($offset){

+    public function offsetExists($offset) {

         return $this->hasParameter($offset);

     }   

     

@@ -42,7 +42,7 @@ 
      * @param $offset 

      * @return 

      */

-    public function offsetGet($offset){

+    public function offsetGet($offset) {

         return $this->getParameter($offset);

     }

     

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

      * @return 

      */

-    public function offsetUnset($name){

+    public function offsetUnset($name) {

         $this->deleteParameter($name);

     }   

 

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

      * @return 

      */

-    public function offsetSet($offset, $name){

+    public function offsetSet($offset, $name) {

         $this->setParameter($offeset, $name);

     }