tidal / PEIP

src/ABS/Handler/MessageHandler.php

Spacing +7 added lines, -7 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));      
     }
    
@@ -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)) {

src/Context/XMLContext.php

Spacing +4 added lines, -4 removed lines

@@ -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);
     }
    
@@ -797,7 +797,7 @@ 
      * @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);
     }
 
@@ -805,9 +805,9 @@ 
      * @param string $type
      * @param string $name
      */
-    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/Event/Observable.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
          * @param $observer 
          * @return 
          */
-    public function addObserver(\PEIP\INF\Event\Observer $observer){
+    public function addObserver(\PEIP\INF\Event\Observer $observer) {
         $this->observers[] = $observer;     
     }