tidal / PEIP

src/Base/GenericBuilder.php

Doc Comments +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
      * 
      * @access public
      * @param string $className class-name to create objects for
-     * @param ReflectionClass $reflectionClass reflection-class for class. default: NULL 
+     * @param \ReflectionClass $reflectionClass reflection-class for class. default: NULL 
      * @param boolean $storeRef wether to store a reference for new instance. default: true 
      * @return 
      */

Spacing +10 added lines, -10 removed lines

@@ -43,10 +43,10 @@ 
      * @param boolean $storeRef wether to store a reference for new instance. default: true 
      * @return 
      */
-    public function __construct($className, \ReflectionClass $reflectionClass = NULL, $storeRef = true){
-        if($reflectionClass ){
+    public function __construct($className, \ReflectionClass $reflectionClass = NULL, $storeRef = true) {
+        if ($reflectionClass) {
             
-            if($reflectionClass->getName() != $className){
+            if ($reflectionClass->getName() != $className) {
                 throw new \Exception(
                     'Constructing GenericBuilder with wrong ReflectionClass'
                 );
@@ -56,7 +56,7 @@ 
             $this->reflectionClass = $reflectionClass;
         }
         $this->className = $className;
-        if($storeRef){
+        if ($storeRef) {
             self::$instances[$this->className] = $this;
         }            
     }
@@ -68,8 +68,8 @@ 
      * @param string $className class-name to return builder instance for 
      * @return GenericBuilder builder instance for class
      */
-    public static function getInstance($className){
-        if(!array_key_exists((string)$className, self::$instances)) {
+    public static function getInstance($className) {
+        if (!array_key_exists((string)$className, self::$instances)) {
             new GenericBuilder($className);
         }
         return self::$instances[$className];
@@ -82,9 +82,9 @@ 
      * @param array $arguments array of constructore arguments
      * @return object the created object instance
      */
-    public function build(array $arguments = array()){      
-        if(Test::assertClassHasConstructor($this->className)){
-            if(!Test::assertRequiredConstructorParameters($this->className, $arguments)){
+    public function build(array $arguments = array()) {      
+        if (Test::assertClassHasConstructor($this->className)) {
+            if (!Test::assertRequiredConstructorParameters($this->className, $arguments)) {
                 throw new \Exception('Missing Argument '.(count($arguments) + 1).' for '.$this->className.'::__construct');
             }
             return $this->getReflectionClass()->newInstanceArgs($arguments);
@@ -98,7 +98,7 @@ 
      * @access public
      * @return ReflectionClass
      */
-    public function getReflectionClass(){
+    public function getReflectionClass() {
         return ReflectionPool::getInstance($this->className);
     }
     

src/Event/EventBuilder.php

Doc Comments -1 removed lines

@@ -83,7 +83,6 @@
      * @param ObjectEventDispatcher $dispatcher the dispatcher to dispatch the event 
      * @param mixed $subject the subject for the event
      * @param string $name the name of the event
-     * @param array $parameters the headers for the event
      * @return 
      */
     public function buildAndDispatch(ObjectEventDispatcher $dispatcher, $subject, $name, array $headers = array()){

Spacing +4 added lines, -4 removed lines

@@ -37,7 +37,7 @@ 
      * @param string $eventClass the event-class the builder shall create instances for 
      * @param array $defaultHeaders default headers for the created events 
      */
-    public function __construct($eventClass = '\PEIP\Event\Event', array $defaultHeaders = array()){
+    public function __construct($eventClass = '\PEIP\Event\Event', array $defaultHeaders = array()) {
         $this->eventClass = $eventClass;
         $this->defaultParameters = $defaultHeaders;
     }
@@ -49,7 +49,7 @@ 
      * @param string $eventClass the event-class the builder shall create instances for 
      * @return EventBuilder the instance of EventBuilder for the given event-class 
      */    
-    public static function getInstance($eventClass = '\PEIP\Event\Event'){ 
+    public static function getInstance($eventClass = '\PEIP\Event\Event') { 
 
         return isset(self::$instances[$eventClass]) 
             ? self::$instances[$eventClass] 
@@ -67,7 +67,7 @@ 
      * @param array $headers the headers for the event 
      * @return object event instance
      */
-    public function build($subject, $name, array $headers = array()){
+    public function build($subject, $name, array $headers = array()) {
 
         return new $this->eventClass(
             $subject,
@@ -86,7 +86,7 @@ 
      * @param array $parameters the headers for the event
      * @return 
      */
-    public function buildAndDispatch(ObjectEventDispatcher $dispatcher, $subject, $name, array $headers = array()){
+    public function buildAndDispatch(ObjectEventDispatcher $dispatcher, $subject, $name, array $headers = array()) {
   
         return $dispatcher->notify(
             $name,

src/Util/Test.php

Braces +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
             class_exists($className);
             $res =  ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);            
-        }  catch (\Exception $e){
+        } catch (\Exception $e){
             $res = false; 
         }
         return $res;;

Spacing +29 added lines, -29 removed lines

@@ -15,11 +15,11 @@ 
 class Test {
 
 
-    public static function assertClassHasConstructor($className){
-        return (boolean) ReflectionPool::getInstance($className)->getConstructor();
+    public static function assertClassHasConstructor($className) {
+        return (boolean)ReflectionPool::getInstance($className)->getConstructor();
     }
 
-    public static function assertRequiredConstructorParameters($className, $parameters){
+    public static function assertRequiredConstructorParameters($className, $parameters) {
             return (boolean)
                 !self::assertClassHasConstructor($className) ||
                 count($parameters) >= ReflectionPool::getInstance($className)
@@ -27,55 +27,55 @@ 
                     ->getNumberOfRequiredParameters();
     }
 
-    public static function assertInstanceOf($className, $object){
-        return (boolean) ReflectionPool::getInstance($className)
+    public static function assertInstanceOf($className, $object) {
+        return (boolean)ReflectionPool::getInstance($className)
             ->isInstance($object);
     }
 
-    public static function assertClassOrInterfaceExists($className){
-        return (boolean) class_exists($className) || interface_exists($className);
+    public static function assertClassOrInterfaceExists($className) {
+        return (boolean)class_exists($className) || interface_exists($className);
     }
 
-    public static function assertImplements($className, $interfaceName){
+    public static function assertImplements($className, $interfaceName) {
         $className = is_object($className) ? get_class($className) : $className;
-        $res = false;//throw new \Exception();
+        $res = false; //throw new \Exception();
         try {  
             class_exists($className); 
-            $res =  ReflectionPool::getInstance($className)
+            $res = ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);             
-        }  catch (\Exception $e){
+        } catch (\Exception $e) {
             $res = false; 
         } 
-        return $res;;
+        return $res; ;
     }
 
-    public static function assertMessage($message){
+    public static function assertMessage($message) {
         return self::assertImplements($message, '\PEIP\INF\Message\Message');
     }
 
-    public static function assertEvent($event){
+    public static function assertEvent($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event');
     }
 
-    public static function assertEventSubject($event){
+    public static function assertEventSubject($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event')
             && $event->getSubject();
     }
 
-    public static function assertEventObjectSubject($event){
+    public static function assertEventObjectSubject($event) {
         return self::assertEventSubject($event)
             && is_object($event->getSubject());
     }
-    public static function assertArrayAccess($var){
-        return (boolean) is_array($var) || $var instanceof \ArrayAccess;
+    public static function assertArrayAccess($var) {
+        return (boolean)is_array($var) || $var instanceof \ArrayAccess;
     }
 
-    public static function assertHandler($var){
-        return (boolean) is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
+    public static function assertHandler($var) {
+        return (boolean)is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
     }
 
-    public static function castType($var, $type){
-        switch($type){
+    public static function castType($var, $type) {
+        switch ($type) {
             case 'string':
                 $var = (string)$var;
                 break;
@@ -99,8 +99,8 @@ 
         return $var;
     }
 
-    public static function ensureArrayAccess($var){
-        if(!Test::assertArrayAccess($var)){
+    public static function ensureArrayAccess($var) {
+        if (!Test::assertArrayAccess($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an array nor an instance of ArrayAccess'
             );
@@ -109,8 +109,8 @@ 
     }
 
 
-    public static function ensureHandler($var){
-        if(!Test::assertHandler($var)){
+    public static function ensureHandler($var) {
+        if (!Test::assertHandler($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an callable nor an instance of \PEIP\INF\Handler\Handler'
             );
@@ -118,8 +118,8 @@ 
         return $var;
     }
 
-    public static function ensureImplements($className, $interfaceName){
-        if(!Test::assertImplements($className, $interfaceName)){
+    public static function ensureImplements($className, $interfaceName) {
+        if (!Test::assertImplements($className, $interfaceName)) {
             throw new \InvalidArgumentException(
                 'Class "'.$className.'" is not an instanceof "'.$interfaceName.'"'
             );
@@ -127,7 +127,7 @@ 
         return $className;
     }
 
-    public static function assertMethod($className, $methodname){
+    public static function assertMethod($className, $methodname) {
         return ReflectionPool::getInstance($className)->hasMethod($methodname);
     }
 

src/ABS/Handler/DiscardingMessageHandler.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param $discardChannel 
      * @return 
      */
-    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel){
+    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel) {
         $this->discardChannel = $discardChannel;    
     }   
 
@@ -42,7 +42,7 @@ 
      * @access public
      * @return 
      */
-    public function getDiscardChannel(){
+    public function getDiscardChannel() {
         return $this->discardChannel;   
     }   
 
@@ -52,8 +52,8 @@ 
      * @param $message 
      * @return 
      */
-    protected function discardMessage(\PEIP\INF\Message\Message $message){
-        if(isset($this->discardChannel)){
+    protected function discardMessage(\PEIP\INF\Message\Message $message) {
+        if (isset($this->discardChannel)) {
             $this->discardChannel->send($message);
         }
     }

src/INF/Base/Singleton.php

Spacing +1 added lines, -1 removed lines

@@ -22,6 +22,6 @@
 
 interface Singleton {
 
-    public static function getInstance ();
+    public static function getInstance();
 
 }

src/ABS/Base/Connectable.php

Doc Comments +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
     
     /**
      * @access public
-     * @param $name
+     * @param string $name
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 
  */
 
-abstract class Connectable  implements \PEIP\INF\Event\Connectable{
+abstract class Connectable  implements \PEIP\INF\Event\Connectable {
 
     const
         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',
@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->connect($name, $this, $listener);
         $this->doFireEvent(
@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function disconnect($name, $listener){
+    public function disconnect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->disconnect($name, $this, $listener);
         $this->doFireEvent(
@@ -82,7 +82,7 @@ 
      * @param $name
      * @return
      */
-    public function hasListeners($name){
+    public function hasListeners($name) {
         return $this->getEventDispatcher()->hasListeners($name, $this);
     }
 
@@ -92,7 +92,7 @@ 
      * @param $name
      * @return
      */
-    public function getListeners($name){
+    public function getListeners($name) {
         return $this->getEventDispatcher()->getListeners($name, $this);
     }
 
@@ -102,7 +102,7 @@ 
      * @param $callable
      * @return
      */
-    public function disconnectAll($name){
+    public function disconnectAll($name) {
         $this->getEventDispatcher()->disconnectAll($name, $this);
     }
 
@@ -112,11 +112,11 @@ 
      * @param $transferListners
      * @return
      */
-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){
-        if($transferListners){
-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){
-                if($this->getEventDispatcher()->hasListeners($name, $this)){
-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){
+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {
+        if ($transferListners) {
+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {
+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {
+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {
                         $dispatcher->connect($name, $this, $listener);
                     }
                 }
@@ -131,11 +131,11 @@ 
      * @access public
      * @return
      */
-    public function getEventDispatcher(){
+    public function getEventDispatcher() {
         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();
     }
 
-    protected static function getSharedEventDispatcher(){
+    protected static function getSharedEventDispatcher() {
         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;
         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;
     }
@@ -148,12 +148,12 @@ 
      * @param $eventClass
      * @return
      */
-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){
+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {
         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;
         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);
     }
 
-    protected static function getDefaultEventClass(){
+    protected static function getDefaultEventClass() {
         return self::DEFAULT_EVENT_CLASS;
     }
 }

src/ABS/Dispatcher/MapDispatcher.php

Doc Comments -1 removed lines

@@ -80,7 +80,6 @@
      *
      * @access public
      * @param string $name name of the event
-     * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return
      */
     public function disconnectAll($name){

Indentation +3 added lines, -3 removed lines

@@ -47,7 +47,7 @@ 
     public function connect($name, $listener){
         Test::ensureHandler($listener);
         if (!$this->hasListeners($name)){
-          $this->listeners[$name] = array();
+            $this->listeners[$name] = array();
         }
         $this->listeners[$name][] = $listener;
         return true;
@@ -67,10 +67,10 @@ 
         }
         $res = false;
         foreach ($this->listeners[$name] as $i => $callable){
-          if ($listener === $callable){
+            if ($listener === $callable){
             unset($this->listeners[$name][$i]);
             $res = true;
-          }
+            }
         }
         return $res;
     }

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/Handler/MessageHandler.php

Doc Comments +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
      * @see PEIP\ABS\Handler\MessageHandler::doSetInputChannel
      * @access public
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel
-     * @return PEIP\ABS\Handler\MessageHandler $this;
+     * @return MessageHandler $this;
      */
     public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){
         $this->doSetInputChannel($inputChannel);

Indentation +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
      * @return 
      */
     public function handle($message){
-         $this->doHandle($this->getMessageFromObject($message));      
+            $this->doHandle($this->getMessageFromObject($message));      
     }
    
     /**
@@ -90,7 +90,7 @@ 
             && $object->getName() == 'postSend'
             && $object->hasHeader(Pipe::HEADER_MESSAGE)
             && $content instanceof \PEIP\INF\Channel\PollableChannel
-         ){
+            ){
             $object = $content->receive();
         }
         if (!($object instanceof \PEIP\INF\Message\Message)) {

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

Braces +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
         $this->inputChannel = $inputChannel;    
         if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){
                 $this->inputChannel->subscribe($this);
-        }else{          
+        } else{          
             $this->unwrapEvents = true;
             $this->inputChannel->connect('postSend', $this);
         }  

src/ABS/Handler/ReplyProducingMessageHandler.php

Doc Comments +3 added lines, -3 removed lines

@@ -51,7 +51,7 @@ 
      * Connects the handler to the output-channel. 
      * 
      * @access protected
-     * @param \PEIP\INF\Channel\Channel $inputChannel the output-channel to connect the handler to
+     * @param \PEIP\INF\Channel\Channel $outputChannel the output-channel to connect the handler to
      * @return 
      */
     protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
@@ -160,7 +160,7 @@ 
      * 
      * @access public
      * @param string $messageClass name of the message-class to create reply-messages from. 
-     * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
+     * @return ReplyProducingMessageHandler $this
      */
     public function setMessageClass($messageClass){
         $this->messageClass = $messageClass;
@@ -193,7 +193,7 @@ 
      * 
      * @access public
      * @param array $headerNames array of message-header names to look for a reply-channel
-     * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
+     * @return ReplyProducingMessageHandler $this
      */
     public function setReplyChannelHeaders(array $headerNames){
         $this->replyChannelHeaders = $headerNames;

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