tidal / PEIP

src/Service/ServiceActivator.php

Spacing +3 added lines, -3 removed lines

@@ -33,12 +33,12 @@
      * @param $outputChannel 
      * @return 
      */
-    public function __construct($serviceCallable, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct($serviceCallable, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->serviceCallable = $serviceCallable;
-        if(is_object($inputChannel)){
+        if (is_object($inputChannel)) {
             $this->setInputChannel($inputChannel);
         }
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);    
         }   
     }       

src/Service/SplittingServiceActivator.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@
      * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload
      * @return mixed result of calling the registered service callable with message content/payload
      */
-    public function callService(\PEIP\INF\Message\Message $message){
-        if(is_callable($this->serviceCallable)){
+    public function callService(\PEIP\INF\Message\Message $message) {
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func_array($this->serviceCallable, $message->getContent());
-        }elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               
         }
         return $res;

src/Service/ServiceContainerBuilder.php

Spacing +7 added lines, -7 removed lines

@@ -25,7 +25,7 @@ 
 use \PEIP\Data\InternalStoreAbstract;
 use PEIP\Factory\DedicatedFactory;
 
-class ServiceContainerBuilder extends \PEIP\Data\InternalStoreAbstract{
+class ServiceContainerBuilder extends \PEIP\Data\InternalStoreAbstract {
     
     
     
@@ -35,7 +35,7 @@ 
      * @param $factory 
      * @return 
      */
-    public function setFactory($key, DedicatedFactory $factory){
+    public function setFactory($key, DedicatedFactory $factory) {
             $this->setInternalValue($key, $factory);
     }
 
@@ -45,7 +45,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getFactory($key){
+    public function getFactory($key) {
             $this->getInternalValue($key);
     }
 
@@ -55,7 +55,7 @@ 
      * @param $key 
      * @return 
      */
-    public function hasFactory($key){
+    public function hasFactory($key) {
             $this->hasInternalValue($key);
     }
 
@@ -65,7 +65,7 @@ 
      * @param $key 
      * @return 
      */
-    public function deleteFactory($key){
+    public function deleteFactory($key) {
             $this->deleteInternalValue($key);
     }
 
@@ -75,7 +75,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getService($key){
+    public function getService($key) {
         return isset($this->services[$key]) ? $this->services[$key] : $this->services[$key] = $this->getFactory($key)->build();
     }
     
@@ -86,7 +86,7 @@ 
      * @param $key 
      * @return 
      */
-    public function buildService($key){
+    public function buildService($key) {
         return $this->getFactory($key)->build();
     }   
     

src/Service/ServiceContainer.php

Spacing +5 added lines, -5 removed lines

@@ -27,7 +27,7 @@ 
 class ServiceContainer
     extends \PEIP\ABS\Base\Connectable
     implements 
-        \PEIP\INF\Service\ServiceContainer{
+        \PEIP\INF\Service\ServiceContainer {
 
     protected $services = array();
     
@@ -45,7 +45,7 @@ 
      * @param $service 
      * @return 
      */
-    public function setService($key, $service){
+    public function setService($key, $service) {
         $this->services[$key] = $service;
     }
     
@@ -55,7 +55,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getService($key){
+    public function getService($key) {
         return $this->services[$key];
     }
     
@@ -65,7 +65,7 @@ 
      * @param $key 
      * @return 
      */
-    public function hasService($key){
+    public function hasService($key) {
         return array_key_exists($key, $this->services); 
     }   
 
@@ -75,7 +75,7 @@ 
      * @param $key 
      * @return 
      */
-    public function deleteService($key){
+    public function deleteService($key) {
         unset($this->services[$key]);
     }
     

src/Service/HeaderServiceActivator.php

Spacing +6 added lines, -6 removed lines

@@ -12,7 +12,7 @@ 
  * @author timo
  */
 
-class HeaderServiceActivator extends \PEIP\Service\ServiceActivator{
+class HeaderServiceActivator extends \PEIP\Service\ServiceActivator {
    
     protected $headerName;
 
@@ -24,7 +24,7 @@ 
      * @param $outputChannel
      * @return
      */
-    public function __construct($serviceCallable, $headerName, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct($serviceCallable, $headerName, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->headerName = $headerName;
         parent::__construct($serviceCallable, $inputChannel, $outputChannel);
     }
@@ -38,12 +38,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload
      * @return mixed result of calling the registered service callable with message content/payload
      */
-    protected function callService(\PEIP\INF\Message\Message $message){
+    protected function callService(\PEIP\INF\Message\Message $message) {
         $res = NULL; 
-        if(is_callable($this->serviceCallable)){
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func($this->serviceCallable, $message->getHeader($this->headerName));
-        }else{
-            if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }else {
+            if (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
                 $res = $this->serviceCallable->handle($message->getHeader($this->headerName));
             }
         }

src/INF/Message/MessageDispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -26,11 +26,11 @@
 
   public function disconnect($name, \PEIP\INF\Message\MessageHandler $handler);
 
-  public function notify( $event);
+  public function notify($event);
 
-  public function notifyUntil( $event);
+  public function notifyUntil($event);
 
-  public function filter( $event, $value);
+  public function filter($event, $value);
 
   public function hasListeners($name);
 

src/INF/Dispatcher/ListDispatcher.php

Spacing +2 added lines, -2 removed lines

@@ -24,9 +24,9 @@
 
 interface ListDispatcher extends \PEIP\INF\Dispatcher\Dispatcher {
 
-  public function connect( $handler);
+  public function connect($handler);
 
-  public function disconnect( $handler);
+  public function disconnect($handler);
 
   public function hasListeners();
 

src/Listener/Wiretap.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@ 
      * @param $outputChannel 
      * @return 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->setEventName('preSend');
         $this->setInputChannel($inputChannel);
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);
         }           
     }           
@@ -47,7 +47,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doReply(\PEIP\INF\Message\Message $message){
+    protected function doReply(\PEIP\INF\Message\Message $message) {
         $this->replyMessage($message->getHeader('MESSAGE'));
     }
     

src/Handler/CallableHandler.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param callable $callable the callable to wrap with the handler 
      * @return 
      */
-    public function __construct($callable){
+    public function __construct($callable) {
         $this->callable = $callable;    
     }
         
@@ -45,7 +45,7 @@ 
      * @param mixed $subject the subject to handle
      * @return mixed result of calling the registered callable with given subject
      */
-    public function handle($subject){
+    public function handle($subject) {
         return call_user_func($this->callable, $subject);
     }
     
@@ -58,7 +58,7 @@ 
      * @return mixed result of calling the registered callable with given subject
      * @see CallableHandler::handle 
      */
-    public function __invoke($subject){
+    public function __invoke($subject) {
         return $this->handle($subject); 
     }
     
@@ -68,7 +68,7 @@ 
      * @access public
      * @return callable callable wrapped by the handler
      */
-    public function getCallable(){
+    public function getCallable() {
         return $this->callable;
     }