tidal / PEIP

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

         }            

     }       

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

             }

         }

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