tidal / PEIP

src/Message/GenericMessage.php

Indentation +5 added lines, -5 removed lines

@@ -76,11 +76,11 @@
     }

 

         /**

-     * returns all headers of the message

-     * 

-     * @access public

-     * @return ArrayAccess ArrayAccess object of headers

-     */

+         * returns all headers of the message

+         * 

+         * @access public

+         * @return ArrayAccess ArrayAccess object of headers

+         */

     public function getHeaders(){

         return (array) $this->headers;

     }

Spacing +15 added lines, -15 removed lines

@@ -41,7 +41,7 @@ 
      * @param mixed $content The content/payload of the message 

      * @param array|ArrayAccess $headers headers as key/value pairs

      */

-    public function __construct($content, $headers = array()){

+    public function __construct($content, $headers = array()) {

         $this->doSetContent($content);

         $this->doSetHeaders($headers);          

     }

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

      * @return

      */

-    public function getContent(){

+    public function getContent() {

         return $this->content;

     }

 

@@ -63,13 +63,13 @@ 
      * @access protected

      * @param mixed $content The content/payload of the message 

      */

-    protected function doSetContent($content){

+    protected function doSetContent($content) {

         $this->content = Test::castType($content, self::CONTENT_CAST_TYPE);

     }

 

-    protected function doSetHeaders($headers){

+    protected function doSetHeaders($headers) {

         $headers = Test::ensureArrayAccess($headers);

-        if(is_array($headers)){

+        if (is_array($headers)) {

             $headers = new \ArrayObject($headers);

         }

         $this->headers = $headers;

@@ -81,8 +81,8 @@ 
      * @access public

      * @return ArrayAccess ArrayAccess object of headers

      */

-    public function getHeaders(){

-        return (array) $this->headers;

+    public function getHeaders() {

+        return (array)$this->headers;

     }

   

     /**

@@ -92,7 +92,7 @@ 
      * @param string $name the name of the header  

      * @return mixed the value of the header

      */

-    public function getHeader($name){

+    public function getHeader($name) {

         $name = (string)$name;

         return isset($this->headers[$name]) ? $this->headers[$name] : NULL;

     }

@@ -105,8 +105,8 @@ 
      * @param string $name the name of the header

      * @return boolean wether the header has been successfully  set

      */

-    public function addHeader($name, $value){

-        if(!$this->hasHeader($name)){

+    public function addHeader($name, $value) {

+        if (!$this->hasHeader($name)) {

             $this->headers[$name] = $value;

             return true;

         }

@@ -120,7 +120,7 @@ 
      * @param string $name the name of the header

      * @return boolean wether the header is set

      */

-    public function hasHeader($name){

+    public function hasHeader($name) {

         return isset($this->headers[$name]);

     }

 

@@ -130,16 +130,16 @@ 
      * @access public

      * @return string  content/payload of the message

      */

-    public function __toString(){

+    public function __toString() {

         $res = false;

         try {

             $res = (string)$this->getContent();

         }

-        catch(\Exception $e){           

+        catch (\Exception $e) {           

             try {

                 $res = get_class($this->getContent());

             }

-            catch(\Exception $e){

+            catch (\Exception $e) {

 

             }

         }

@@ -159,7 +159,7 @@ 
      * @param array $arguments argumends for the constructor

      * @return GenericMessage new class instance

      */    

-    public static function build(array $arguments = array()){

+    public static function build(array $arguments = array()) {

         return GenericBuilder::getInstance(__CLASS__)->build($arguments);

     }     

 } 
\ No newline at end of file

Braces +2 added lines, -4 removed lines

@@ -134,12 +134,10 @@
         $res = false;

         try {

             $res = (string)$this->getContent();

-        }

-        catch(\Exception $e){           

+        } catch(\Exception $e){           

             try {

                 $res = get_class($this->getContent());

-            }

-            catch(\Exception $e){

+            } catch(\Exception $e){

 

             }

         }

src/Message/ErrorMessage.php

Spacing +1 added lines, -1 removed lines

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

      * @return 

      */

-    public function __construct(\Exception $payload, array $headers = array()){

+    public function __construct(\Exception $payload, array $headers = array()) {

         $this->payload = $payload;

         $this->headers = $headers;

     }

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

         }            

     }       

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

         }            

     }       

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