tidal / PEIP

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

src/Event/Observable.php

Spacing +14 added lines, -14 removed lines

@@ -36,12 +36,12 @@ 
      * @param $observedObject 
      * @return 
      */
-    public function __construct($observedObject){
+    public function __construct($observedObject) {
         $this->setObserved($observedObject);
     }
 
-    protected function setObserved($observedObject){
-        if(!is_object($observedObject)){
+    protected function setObserved($observedObject) {
+        if (!is_object($observedObject)) {
             throw new \InvalidArgumentException("$observedObject must be an object. ".gettype($var)." given.");
         }
         
@@ -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;     
     }
 
@@ -63,9 +63,9 @@ 
      * @param $observer 
      * @return 
      */
-    public function deleteObserver(\PEIP\INF\Event\Observer $observer){
-        foreach($this->observers as $key=>$obs){
-            if($obs == $observer){
+    public function deleteObserver(\PEIP\INF\Event\Observer $observer) {
+        foreach ($this->observers as $key=>$obs) {
+            if ($obs == $observer) {
                 unset($this->observers[$key]);
                 return true;
             }
@@ -78,9 +78,9 @@ 
      * @param $arguments 
      * @return 
      */
-    public function notifyObservers(array $arguments = array()){
-        if($this->hasChanged()){
-            foreach($this->observers as $observer){
+    public function notifyObservers(array $arguments = array()) {
+        if ($this->hasChanged()) {
+            foreach ($this->observers as $observer) {
                 $observer->update($this->observedObject);
             }       
         }
@@ -91,7 +91,7 @@ 
      * @access public
      * @return 
      */
-    public function countObservers(){
+    public function countObservers() {
         return count($this->obeservers);
     }
     
@@ -100,7 +100,7 @@ 
      * @access public
      * @return 
      */
-    public function hasChanged(){
+    public function hasChanged() {
         return $this->hasChanged();
     }
     
@@ -109,7 +109,7 @@ 
      * @access public
      * @return 
      */
-    public function setChanged(){
+    public function setChanged() {
         $this->hasChanged = true;
     }
 
@@ -118,7 +118,7 @@ 
      * @access public
      * @return 
      */
-    public function clearChanged(){
+    public function clearChanged() {
         $this->hasChanged = true;   
     }
 

src/Event/Event.php

Spacing +9 added lines, -9 removed lines

@@ -51,7 +51,7 @@ 
      * @param string $name the name of the event
      * @param array|ArrayAccess $headers the headers for the event 
      */
-    public function __construct($subject, $name, $parameters = array(), $type = false){
+    public function __construct($subject, $name, $parameters = array(), $type = false) {
         parent::__construct($subject, Test::ensureArrayAccess($parameters));
         $this->name = $name;
         $this->type = $type ? $type : get_class($this);
@@ -63,7 +63,7 @@ 
      * @access public
      * @return string the name of the event
      */
-    public function getName(){
+    public function getName() {
         return $this->name;
     }
 
@@ -74,7 +74,7 @@ 
      * @access public
      * @return string the type of the event
      */
-    public function getType(){
+    public function getType() {
         return $this->name;
     }
   
@@ -84,7 +84,7 @@ 
      * @access public
      * @param mixed $value the return-value to set 
      */
-    public function setReturnValue($value){
+    public function setReturnValue($value) {
         $this->value = $value;
     }
   
@@ -94,7 +94,7 @@ 
      * @access public
      * @return mixed the return-value to set
      */
-    public function getReturnValue(){
+    public function getReturnValue() {
         return $this->value;
     }
   
@@ -104,8 +104,8 @@ 
      * @access public
      * @param boolean $processed 
      */
-    public function setProcessed($processed){
-        $this->processed = (boolean) $processed;
+    public function setProcessed($processed) {
+        $this->processed = (boolean)$processed;
     }
 
     /**
@@ -114,7 +114,7 @@ 
      * @access public
      * @return boolean wether the event is processed 
      */
-    public function isProcessed(){
+    public function isProcessed() {
         return $this->processed;
     }
 
@@ -124,7 +124,7 @@ 
      * @access public
      * @return mixed the subject/content
      */
-    public function getSubject(){
+    public function getSubject() {
         return $this->getContent();
     }
 }

src/Dispatcher/EventClassDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -25,9 +25,9 @@ 
      * @param \PEIP\INF\Event\Event $object an event object
      * @return boolean
      */
-    public function notify($name, $object){ 
-        if($object instanceof \PEIP\INF\Event\Event){
-            if(is_object($object->getContent())){
+    public function notify($name, $object) { 
+        if ($object instanceof \PEIP\INF\Event\Event) {
+            if (is_object($object->getContent())) {
                 return self::doNotify(
                     $this->getListeners(
                         $name,
@@ -35,10 +35,10 @@ 
                      ),
                      $object->getContent()
                  );
-            }else{
+            }else {
                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
             }
-        }else{
+        }else {
             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
         }
     }       //put your code here
@@ -55,8 +55,8 @@ 
      * @return
      * @see EventBuilder
      */
-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){
-        if(!$this->hasListeners($name, ($object))){
+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {
+        if (!$this->hasListeners($name, ($object))) {
             return false;
         }
 
@@ -79,7 +79,7 @@ 
      * @param object $object object to check for listeners
      * @return boolean
      */
-    public function hasListeners($name, $object){
+    public function hasListeners($name, $object) {
         return parent::hasListeners(
             $name,
             ReflectionPool::getInstance($object)