tidal / PEIP

src/Context/XMLContext.php

Spacing +95 added lines, -95 removed lines

@@ -50,24 +50,24 @@ 
      * @param string $string the configuration string 
      * @return 
      */
-    public function __construct($string){
+    public function __construct($string) {
         $this->initNodeBuilders();
         $reader = new XMLContextReader($string);
  
 
         $serviceActivator = new HeaderServiceActivator(array($this, 'addConfig'), 'NODE');
 
-        $reader->connect('read_node',  $serviceActivator);
+        $reader->connect('read_node', $serviceActivator);
         $reader->read();
 
        
     }
 
-    public function addConfig($config){ 
+    public function addConfig($config) { 
         return $this->getServiceProvider()->addConfig($config);
     }
 
-    public function handleReadConfig(\PEIP\INF\Event\Event $event){
+    public function handleReadConfig(\PEIP\INF\Event\Event $event) {
         $this->addConfig($event->getHeader('NODE'));
     }
 
@@ -79,7 +79,7 @@ 
      * @return XMLContext the context instance
      * @throws RuntimeException 
      */      
-    public static function createFromString($string){
+    public static function createFromString($string) {
         return new XMLContext($string);
     }
 
@@ -91,10 +91,10 @@ 
      * @return XMLContext the context instance
      * @throws RuntimeException 
      */    
-    public static function createFromFile($file){
-        if(file_exists($file)){
+    public static function createFromFile($file) {
+        if (file_exists($file)) {
             return self::createFromString(file_get_contents($file));
-        }else{
+        }else {
             throw new \RuntimeException('Cannot open file  "'.$file.'".');
         }
     }
@@ -105,15 +105,15 @@ 
      * @access protected
      * @return void
      */
-    protected function init(){
+    protected function init() {
         $xml = $this->simpleXML;
         $this->channelRegistry = ChannelRegistry::getInstance();
         // register this context as a service if id is set.
-        if($xml['id']){
+        if ($xml['id']) {
             $this->services[(string)$xml['id']] = $this;    
         }
         // build services
-        foreach($xml->children() as $entry){
+        foreach ($xml->children() as $entry) {
             $this->buildNode($entry);
         }
     }    
@@ -126,7 +126,7 @@ 
      * @param string $nodeName the name of the node 
      * @param callable $callable a callable which creates instances for node-name 
      */
-    public function registerNodeBuilder($nodeName, $callable){
+    public function registerNodeBuilder($nodeName, $callable) {
        return  $this->getServiceProvider()->registerNodeBuilder($nodeName, $callable);
     }
    
@@ -137,7 +137,7 @@ 
      * @access public
      * @param \PEIP\INF\Context\Context_Plugin $plugin a plugin instance
      */
-    public function addPlugin(\PEIP\INF\Context\ContextPlugin $plugin){ 
+    public function addPlugin(\PEIP\INF\Context\ContextPlugin $plugin) { 
         $plugin->init($this);   
     }
   
@@ -148,7 +148,7 @@ 
      * @param object $config configuration object for the plugin 
      * @return 
      */
-    public function createPlugin($config){
+    public function createPlugin($config) {
         $plugin = $this->createService($config);    
         $this->addPlugin($plugin);
     }
@@ -169,7 +169,7 @@ 
      * @access public
      * @param XMLContext $config the config to include
      */    
-    public function includeContext(XMLContext $context){
+    public function includeContext(XMLContext $context) {
         $this->services = array_merge($this->services, $context->getServices());
     }
 
@@ -180,8 +180,8 @@ 
      * @access public
      * @param XMLContext $context the config to include
      */    
-    public function includeContextFromFile($filePath){
-        if(file_exists($filePath)){
+    public function includeContextFromFile($filePath) {
+        if (file_exists($filePath)) {
             $this->includeContextFromString(file_get_contents($filePath));
         }           
     }
@@ -193,7 +193,7 @@ 
      * @access public
      * @param string $configString the config to include
      */    
-    public function includeContextFromString($configString){
+    public function includeContextFromString($configString) {
         $context = new XMLContext($configString);
         $this->includeContext($context);            
     }   
@@ -205,14 +205,14 @@ 
      * @access protected
      * @param object $config the configuration for the context
      */    
-    protected function createContext($config){
-        if((string)$config['file'] != ''){
+    protected function createContext($config) {
+        if ((string)$config['file'] != '') {
             $this->includeContextFromFile((string)$config['file']);
         }           
     }   
      
 
-    public function getServiceProvider(){
+    public function getServiceProvider() {
         return isset($this->serviceProvider)
             ? $this->serviceProvider
             : $this->serviceProvider = new ServiceProvider();
@@ -228,7 +228,7 @@ 
      * @see XMLContext::includeContext
      * @access protected
      */     
-    protected function initNodeBuilders(){
+    protected function initNodeBuilders() {
         $builders = array(
             'include' => 'createContext',
             'plugin' => 'createPlugin',
@@ -246,7 +246,7 @@ 
         );
         $plugin = new BasePlugin();
         $this->addPlugin($plugin); 
-        foreach($builders as $nodeName => $method){
+        foreach ($builders as $nodeName => $method) {
             $this->registerNodeBuilder($nodeName, array($this, $method));   
         }       
     }
@@ -260,10 +260,10 @@ 
      * @param object $node configuration-node
      * @return void
      */
-    protected function buildNode($node){
+    protected function buildNode($node) {
         $nodeName = $node->getName();
         // call the builder method registered for the node.
-        if(array_key_exists($nodeName, $this->nodeBuilders)){
+        if (array_key_exists($nodeName, $this->nodeBuilders)) {
             call_user_func($this->nodeBuilders[$nodeName], $node);
         }           
     }
@@ -282,7 +282,7 @@ 
      * @param string $channelName the name/id of the channel to return 
      * @return \PEIP\INF\Channel\Channel
      */
-    public function resolveChannelName($channelName){
+    public function resolveChannelName($channelName) {
         return $this->channelRegistry->get($channelName);
     }   
      
@@ -294,7 +294,7 @@ 
      * @param mixed $id the id for the service
      * @return object the service instance if found
      */
-    public function getService($id){     
+    public function getService($id) {     
         return $this->getServiceProvider()->provideService($id);
     }
              
@@ -304,7 +304,7 @@ 
      * @access public
      * @return array registered services
      */
-    public function getServices(){    
+    public function getServices() {    
         return $this->getServiceProvider()->getServices();
     }  
     
@@ -315,7 +315,7 @@ 
      * @param mixed $id the id for the service 
      * @return boolean wether service is registered
      */
-    public function hasService($id){
+    public function hasService($id) {
         return isset($this->services[$id]);
     }
       
@@ -329,9 +329,9 @@ 
      * @return object the service instance if found
      * 
      */
-    protected function requestService($id){
+    protected function requestService($id) {
         $service = $this->getService($id);
-        if($service === NULL){
+        if ($service === NULL) {
             throw new \RuntimeException('Service "'.$id.'" not found.');
         } 
         return $service;
@@ -345,9 +345,9 @@ 
      * @param object $config 
      * @return object the initialized service instance
      */
-    protected function initService($config){
+    protected function initService($config) {
         $id = trim((string)$config['id']);
-        if($id != ''){
+        if ($id != '') {
             return $this->services[$id] = $this->createService($config);    
         }   
     }
@@ -359,7 +359,7 @@ 
      * @param $config 
      * @return object the initialized service instance
      */
-    public function createService($config){
+    public function createService($config) {
         return ServiceFactory::createService($config);      
     }
  
@@ -376,28 +376,28 @@ 
      * @param object $config configuration to get the modification instructions from. 
      * @return object the modificated service
      */
-    protected function modifyService($service, $config){ 
+    protected function modifyService($service, $config) { 
         // set instance properties
-        if($config->property){          
-            foreach($config->property as $property){                          
+        if ($config->property) {          
+            foreach ($config->property as $property) {                          
                 $arg = $this->buildArg($property);
-                if($arg){
+                if ($arg) {
                     $setter = self::getSetter($property);               
-                    if($setter &&  self::hasPublicProperty($service, 'Method', $setter)){
+                    if ($setter && self::hasPublicProperty($service, 'Method', $setter)) {
                         $service->{$setter}($arg);  
-                    }elseif(in_array($property, self::hasPublicProperty($service, 'Property', $setter))){
+                    }elseif (in_array($property, self::hasPublicProperty($service, 'Property', $setter))) {
                         $service->$setter = $arg;
                     }                   
                 }
             }
         }   
         // call instance methods
-        if($config->action){            
-            foreach($config->action as $action){
+        if ($config->action) {            
+            foreach ($config->action as $action) {
                 $method = (string)$action['method'] != '' ? (string)$action['method'] : NULL;
-                if($method && self::hasPublicProperty($service, 'Method', $method)){
+                if ($method && self::hasPublicProperty($service, 'Method', $method)) {
                     $args = array(); 
-                    foreach($action->children() as $argument){
+                    foreach ($action->children() as $argument) {
                         $args[] = $this->buildArg($argument);
                     } 
                     call_user_func_array(array($service, (string)$action['method']), $args);
@@ -405,9 +405,9 @@ 
             }
         }       
         // register instance listeners
-        if($service instanceof \PEIP\INF\Event\Connectable){
-            if($config->listener){
-                foreach($config->listener as $listenerConf){
+        if ($service instanceof \PEIP\INF\Event\Connectable) {
+            if ($config->listener) {
+                foreach ($config->listener as $listenerConf) {
                     $event = (string)$listenerConf['event'];
                     $listener = $this->provideService($listenerConf);  
                     $service->connect($event, $listener);   
@@ -426,7 +426,7 @@ 
      * @param mixed $id the id ofthe gateway 
      * @return object the gateway instance
      */
-    public function getGateway($id){ 
+    public function getGateway($id) { 
         return $this->getServiceProvider()->provideService($id); 
     }   
   
@@ -438,7 +438,7 @@ 
      * @param object $config configuration object for the pollable channel. 
      * @return \PEIP\INF\Channel\Channel the created pollable channel instance
      */
-    public function createChannel($config){
+    public function createChannel($config) {
         return $this->doCreateChannel($config, 'PollableChannel');        
     }
   
@@ -450,7 +450,7 @@ 
      * @param object $config configuration object for the subscribable channel. 
      * @return \PEIP\INF\Channel\Channel the created subscribable channel instance
      */
-    public function createSubscribableChannel($config){
+    public function createSubscribableChannel($config) {
         return $this->doCreateChannel($config, 'PublishSubscribeChannel');       
     }   
    
@@ -463,9 +463,9 @@ 
      * @param $additionalArguments additional arguments for the channel constructor (without first arg = id)
      * @return \PEIP\INF\Channel\Channel the created channel instance
      */
-    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()){
+    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()) {
         $id = (string)$config['id'];
-        if($id != ''){ 
+        if ($id != '') { 
             array_unshift($additionalArguments, $id);
             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);
             $this->channelRegistry->register($channel);
@@ -482,7 +482,7 @@ 
      * @param string $defaultClass the class to use if none is set in config. 
      * @return object the gateway instance
      */
-    public function createGateway($config, $defaultClass = false){
+    public function createGateway($config, $defaultClass = false) {
         $args = array(
             $this->getRequestChannel($config), 
             $this->getReplyChannel($config)
@@ -506,7 +506,7 @@ 
      * @param string $defaultClass the class to use if none is set in config. 
      * @return object the router instance
      */
-    public function createRouter($config, $defaultClass = false){
+    public function createRouter($config, $defaultClass = false) {
         $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;
         return $this->buildAndModify($config, array(
             $resolver,
@@ -523,7 +523,7 @@ 
      * @param object $config configuration object for the splitter. 
      * @return object the splitter instance
      */    
-    public function createSplitter($config){
+    public function createSplitter($config) {
         return $this->createReplyMessageHandler($config);           
     }   
  
@@ -536,7 +536,7 @@ 
      * @param object $config configuration object for the transformer. 
      * @return object the transformer instance
      */    
-    public function createTransformer($config){
+    public function createTransformer($config) {
         return $this->createReplyMessageHandler($config);           
     } 
       
@@ -549,7 +549,7 @@ 
      * @param object $config configuration object for the aggregator. 
      * @return object the aggregator instance
      */  
-    public function createAggregator($config){
+    public function createAggregator($config) {
         return $this->createReplyMessageHandler($config);       
     }
   
@@ -562,7 +562,7 @@ 
      * @param object $config configuration object for the wiretap. 
      * @return object the wiretap instance
      */ 
-    public function createWiretap($config){
+    public function createWiretap($config) {
         return $this->createReplyMessageHandler($config, 'Wiretap');       
     }
   
@@ -575,7 +575,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the reply-message-handler instance
      */ 
-    public function createReplyMessageHandler($config, $defaultClass = false){
+    public function createReplyMessageHandler($config, $defaultClass = false) {
         return $this->buildAndModify($config, $this->getReplyHandlerArguments($config), $defaultClass); 
     }
     
@@ -588,12 +588,12 @@ 
      * @param string $defaultClass the class to use if none is set in config. 
      * @return object the service-activator instance
      */
-    public function createServiceActivator($config, $defaultClass = false){
+    public function createServiceActivator($config, $defaultClass = false) {
         $method = (string)$config['method'];
         $service = $this->getService((string)$config['ref']);
-        if($method && $service){        
+        if ($method && $service) {        
             $args = $this->getReplyHandlerArguments($config);
-            array_unshift($args,array(
+            array_unshift($args, array(
                 $service,
                 $method             
             )); 
@@ -614,11 +614,11 @@ 
      * @param object $config configuration object for the service. 
      * @return 
      */
-    protected function provideService($config){
+    protected function provideService($config) {
         $ref = trim((string)$config['ref']);
-        if($ref != ''){
+        if ($ref != '') {
             $service = $this->getService($ref); 
-        }else{
+        }else {
             $service = $this->createService($config);
         }
         return $service;
@@ -635,10 +635,10 @@ 
      * @param object $config configuration object for the setter-method. 
      * @return string camel-cased 
      */    
-    protected static function getSetter($config){
-        if($config['setter']){
+    protected static function getSetter($config) {
+        if ($config['setter']) {
             $setter = (string)$config['setter'];
-        }elseif($config['name']){
+        }elseif ($config['name']) {
             $setter = 'set'.ucfirst((string)$config['name']);   
         }
         return $setter;     
@@ -651,29 +651,29 @@ 
      * @param object $config configuration object to create argument from.  
      * @return mixed build argument 
      */
-    protected function buildArg($config){ 
-        if(trim((string)$config['value']) != ''){
+    protected function buildArg($config) { 
+        if (trim((string)$config['value']) != '') {
             $arg = (string)$config['value'];
-        }elseif($config->getName() == 'value'){
+        }elseif ($config->getName() == 'value') {
             $arg = (string)$config;
-        }elseif($config->getName() == 'list'){
+        }elseif ($config->getName() == 'list') {
             $arg = array();
-            foreach($config->children() as $entry){ 
-                if($entry->getName() == 'value'){
-                    if($entry['key']){
+            foreach ($config->children() as $entry) { 
+                if ($entry->getName() == 'value') {
+                    if ($entry['key']) {
                         $arg[(string)$entry['key']] = (string)$entry;   
-                    }else{
+                    }else {
                         $arg[] = (string)$entry;
                     }
-                }elseif($entry->getName() == 'service'){
+                }elseif ($entry->getName() == 'service') {
                     $arg[] = $this->provideService($entry);
                 }
             }
-        }elseif($config->getName() == 'service'){
+        }elseif ($config->getName() == 'service') {
             $arg = $this->provideService($config);
-        }elseif($config->list){
+        }elseif ($config->list) {
             $arg = $this->buildArg($config->list);
-        }elseif($config->service){
+        }elseif ($config->service) {
             $arg = $this->buildArg($config->service);
         } 
         return $arg; 
@@ -687,12 +687,12 @@ 
      * @param object $config configuration object to create arguments from.  
      * @return mixed build arguments 
      */
-    protected function getReplyHandlerArguments($config){
+    protected function getReplyHandlerArguments($config) {
         $args = array(
             $this->doGetChannel('input', $config),
             $this->doGetChannel('output', $config)
         );
-        if($args[0] == NULL){
+        if ($args[0] == NULL) {
             throw new \RuntimeException('Could not receive input channel.');
         }
         return $args;
@@ -707,7 +707,7 @@ 
      * @param object $config configuration object to return request-channel from. 
      * @return \PEIP\INF\Channel\Channel request-channel
      */
-    protected function getRequestChannel($config){
+    protected function getRequestChannel($config) {
         return $this->doGetChannel('request', $config); 
     }
     
@@ -720,7 +720,7 @@ 
      * @param object $config configuration object to return reply-channel from. 
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    protected function getReplyChannel($config){
+    protected function getReplyChannel($config) {
         return $this->doGetChannel('reply', $config);   
     }
     
@@ -733,7 +733,7 @@ 
      * @param object $config configuration object to return channel from. 
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    public function doGetChannel($type, $config){
+    public function doGetChannel($type, $config) {
         $channelName = $config[$type."_channel"] 
             ? $config[$type."_channel"] 
             : $config["default_".$type."_channel"];
@@ -753,7 +753,7 @@ 
      * @param string $defaultClass class to create instance for if none is set in config 
      * @return object build and modified srvice instance
      */
-    public function buildAndModify($config, $arguments, $defaultClass = false){   
+    public function buildAndModify($config, $arguments, $defaultClass = false) {   
         return ServiceFactory::buildAndModify($config, $arguments, $defaultClass);
     }
 
@@ -767,21 +767,21 @@ 
      * @param string $defaultClass class to create instance for if none is set in config 
      * @return object build and modified srvice instance
      */    
-    protected static function doBuild($config, $arguments, $defaultClass = false){
+    protected static function doBuild($config, $arguments, $defaultClass = false) {
         $cls = $config["class"] ? trim((string)$config["class"]) : (string)$defaultClass;
-        if($cls != ''){
+        if ($cls != '') {
             try {
                 $constructor = (string)$config["constructor"];
-        if($constructor != ''){
+        if ($constructor != '') {
             $service = call_user_func_array(array($cls, $constructor), $arguments); 
-        }else{
+        }else {
             $service = self::build($cls, $arguments); 
         }        
-            }catch(\Exception $e){
+            } catch (\Exception $e) {
                 throw new \RuntimeException('Could not create Service "'.$cls.'" -> '.$e->getMessage());
             }           
         }
-        if(is_object($service)){
+        if (is_object($service)) {
             return $service;
         }       
         throw new \RuntimeException('Could not create Service "'.$cls.'". Class does not exist.');           
@@ -797,13 +797,13 @@ 
      * @param array $arguments arguments for the constructor 
      * @return object build and modified srvice instance
      */     
-    protected static function build($className, $arguments){
+    protected static function build($className, $arguments) {
         return GenericBuilder::getInstance($className)->build($arguments);
     }
 
-    protected static function hasPublicProperty($service, $type, $name){
+    protected static function hasPublicProperty($service, $type, $name) {
         $reflection = GenericBuilder::getInstance(get_class($service))->getReflectionClass();
-        if($reflection->{'has'.$type}($name) && $reflection->{'get'.$type}($name)->isPublic()){
+        if ($reflection->{'has'.$type}($name) && $reflection->{'get'.$type}($name)->isPublic()) {
                 return true;
         }
         return false;

src/Context/XMLContextReader.php

Spacing +4 added lines, -4 removed lines

@@ -19,21 +19,21 @@
     protected $config;
 
 
-    public function __construct($config){ 
+    public function __construct($config) { 
         $this->config = ($config);       
     }
 
-    public function read(){      
+    public function read() {      
         $iterator = new \SimpleXMLIterator($this->config);
         $iterator->rewind();
-        while($iterator->valid()){
+        while ($iterator->valid()) {
             
             $arrayNode = XMLArrayTranslator::translate($iterator->current()->asXML()); 
             $this->doFireEvent('read_node', array('NODE'=>$arrayNode));            
             $iterator->next();
         }
         
-        foreach($iterator as $xmlNode){  
+        foreach ($iterator as $xmlNode) {  
 
         }
         $this->config = array();

src/Message/GenericMessage.php

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) {
                 return "";
             }
         }     
@@ -157,7 +157,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

src/Message/TextMessage.php

Spacing +4 added lines, -4 removed lines

@@ -34,7 +34,7 @@ 
      * @param $title 
      * @return 
      */
-    public function __construct($content, $title){
+    public function __construct($content, $title) {
         $this->setContent((string)$content);
     }
 
@@ -44,7 +44,7 @@ 
      * @param $title 
      * @return 
      */
-    public function setTitle($title){
+    public function setTitle($title) {
         $this->title = (string)$title;
     }
 
@@ -53,7 +53,7 @@ 
      * @access public
      * @return 
      */
-    public function getTitle(){
+    public function getTitle() {
         return $this->title;
     }
 
@@ -67,7 +67,7 @@ 
      * @param string $name the name of the header
      * @return boolean wether the header is set
      */
-    public static function build(array $arguments = array()){
+    public static function build(array $arguments = array()) {
         return GenericBuilder::getInstance('\PEIP\Message\StringMessage')->build($arguments);
     }
 

src/Message/MessageBuilder.php

Spacing +13 added lines, -13 removed lines

@@ -39,7 +39,7 @@ 
      * @access public
      * @param string $messageClass the message-class to build instances for 
      */
-    public function __construct($messageClass = '\PEIP\Message\GenericMessage'){
+    public function __construct($messageClass = '\PEIP\Message\GenericMessage') {
         $this->messageClass = $messageClass;
         $this->factory = DedicatedFactory::getfromCallable(array($messageClass, 'build'));    
     }
@@ -51,7 +51,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this
      */
-    public function copyHeaders(array $headers){
+    public function copyHeaders(array $headers) {
         $this->headers = array_merge($this->headers, $headers);
         return $this;       
     }
@@ -63,7 +63,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this
      */
-    public function copyHeadersIfAbsent(array $headers){
+    public function copyHeadersIfAbsent(array $headers) {
         $this->headers = array_merge($headers, $this->headers);
         return $this;   
     }
@@ -75,7 +75,7 @@ 
      * @param string $headerName the name of the header
      * @return MessageBuilder $this
      */
-    public function removeHeader($headerName){
+    public function removeHeader($headerName) {
         unset($this->headers[$headerName]);
         return $this;
     }
@@ -88,7 +88,7 @@ 
      * @param mixed $headerValue the value for the header
      * @return MessageBuilder $this 
      */
-    public function setHeader($headerName, $headerValue){
+    public function setHeader($headerName, $headerValue) {
         $this->headers[$headerName] = $headerValue;
         return $this;   
     }
@@ -100,7 +100,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this 
      */
-    public function setHeaders(array $headers){
+    public function setHeaders(array $headers) {
         $this->headers = $headers;
         return $this;   
     }
@@ -111,7 +111,7 @@ 
      * @access public
      * @return array the headers for the message to build 
      */
-    public function getHeaders(){
+    public function getHeaders() {
         return $this->headers;
     }  
         
@@ -122,7 +122,7 @@ 
      * @param $arguments 
      * @return 
      */
-    public function build(array $headers = array()){
+    public function build(array $headers = array()) {
         $this->copyHeaders($headers);
         return GenericBuilder::getInstance($this->messageClass)
             ->build(array($this->payload, new \ArrayObject($this->headers)));        
@@ -135,7 +135,7 @@ 
      * @param mixed $payload payload for the message to build 
      * @return MessageBuilder $this 
      */
-    public function setContent($payload){
+    public function setContent($payload) {
         $this->payload = $payload;
         return $this;
     }
@@ -148,7 +148,7 @@ 
      * @param string $messageClass the message class to build from the builder 
      * @return MessageBuilder new instance of MessageBuilder 
      */    
-    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage'){
+    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage') {
         return new  MessageBuilder($messageClass);
     }
   
@@ -160,7 +160,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to get class to build from the builder 
      * @return MessageBuilder new instance of MessageBuilder 
      */      
-    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message){
+    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message) {
         return new MessageBuilder(get_class($message));
     }
    
@@ -170,7 +170,7 @@ 
      * @access public
      * @param string $messageClass the message-class to build new instances for
      */
-    public function setMessageClass($messageClass){
+    public function setMessageClass($messageClass) {
         $this->messageClass = $messageClass;
     }
  
@@ -180,7 +180,7 @@ 
      * @access public
      * @return string the message-class to build new instances for
      */
-    public function getMessageClass(){
+    public function getMessageClass() {
         return $this->messageClass;
     }         
 }
\ No newline at end of file

src/Message/CommandMessage.php

Spacing +5 added lines, -5 removed lines

@@ -37,8 +37,8 @@ 
      * @param $headers 
      * @return 
      */
-    public function __construct($content, ArrayAccess $headers = NULL){
-        if(!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)){
+    public function __construct($content, ArrayAccess $headers = NULL) {
+        if (!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)) {
             throw new \BadArgumentException('Argument 1 for CommandMessage::__construct must be callable or implment \PEIP\INF\Command\Command');
         }
         
@@ -51,10 +51,10 @@ 
      * @access public
      * @return 
      */
-    public function execute(){
-        if(is_callable($this->getContent())){
+    public function execute() {
+        if (is_callable($this->getContent())) {
             return call_user_func($this->getContent());
-        }else{
+        }else {
             return $this->getContent()->execute();
         }
     }

src/Message/CallableMessageHandler.php

Spacing +11 added lines, -11 removed lines

@@ -35,7 +35,7 @@ 
      * @param $callable 
      * @return 
      */
-    public function __construct($callable){
+    public function __construct($callable) {
         $this->callable = $callable;    
         $this->examineCallabe();
     }
@@ -45,22 +45,22 @@ 
      * @access protected
      * @return 
      */
-    protected function examineCallabe(){
-        if(is_callable($this->callable)){        
-            if(is_array($this->callable)){
-                list($class, $method) =  $this->callable;
+    protected function examineCallabe() {
+        if (is_callable($this->callable)) {        
+            if (is_array($this->callable)) {
+                list($class, $method) = $this->callable;
                 $static = !is_object($class);
                 $class = is_object($class) ? get_class($class) : (string)$class;
                 $reflectionClass = new \ReflectionClass($class);
                 $reflectionFunc = $reflectionClass->getMethod($method);
-                if($static && !$reflectionFunc->isStatic()){
+                if ($static && !$reflectionFunc->isStatic()) {
                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  
                 }
-            }else{
+            }else {
                 $reflectionFunc = new \ReflectionFunction($this->callable);  
             }
             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();
-        }else{
+        }else {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');
         }   
     }   
@@ -73,14 +73,14 @@ 
      * @param $sent 
      * @return 
      */
-    public function handle($message, $channel = false, $sent = false){
-        if(!is_object($message)){
+    public function handle($message, $channel = false, $sent = false) {
+        if (!is_object($message)) {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::handle is not a Object');       
         }   
         try {
             return call_user_func_array($this->callable, array($message, $channel, $sent));
         }
-        catch(\Exception $e){
+        catch (\Exception $e) {
             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());
         }   
     }   

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/Message/StringMessage.php

Spacing +3 added lines, -3 removed lines

@@ -27,11 +27,11 @@ 
 
     const CONTENT_CAST_TYPE = 'string';
 
-    public function __toString(){
+    public function __toString() {
         return (string)$this->getContent();
     }
 
-    public function getContent(){
+    public function getContent() {
         return (string)parent::getContent();
     }
 
@@ -45,7 +45,7 @@ 
      * @param string $name the name of the header
      * @return boolean wether the header is set
      */     
-    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