@@ -60,11 +60,11 @@ |
||
60 | 60 | $message = NULL; |
61 | 61 | if($timeout == 0){ |
62 | 62 | $message = $this->getMessage(); |
63 | - }elseif($timeout < 0){ |
|
63 | + } elseif($timeout < 0){ |
|
64 | 64 | while(!$message = $this->getMessage()){ |
65 | 65 | |
66 | 66 | } |
67 | - }else{ |
|
67 | + } else{ |
|
68 | 68 | $time = time() + $timeout; |
69 | 69 | while(($time > time()) && !$message = $this->getMessage()){ |
70 | 70 |
@@ -108,7 +108,7 @@ |
||
108 | 108 | //if(\PEIP\Util\Test::assertMessage($message)){ |
109 | 109 | if($this->getOutputChannel()){ |
110 | 110 | $this->getOutputChannel()->send($message); |
111 | - }else{ |
|
111 | + } else{ |
|
112 | 112 | $this->doSend($message); |
113 | 113 | } |
114 | 114 | //} |
@@ -115,8 +115,7 @@ |
||
115 | 115 | $this->send($content); |
116 | 116 | try { |
117 | 117 | $res = $this->receive(); |
118 | - } |
|
119 | - catch(\Exception $e){ |
|
118 | + } catch(\Exception $e){ |
|
120 | 119 | return NULL; |
121 | 120 | } |
122 | 121 | return $res; |
@@ -118,7 +118,7 @@ discard block |
||
118 | 118 | |
119 | 119 | if($this->hasService($key)){ |
120 | 120 | $service = $this->getService($key); |
121 | - }else{ |
|
121 | + } else{ |
|
122 | 122 | $service = $this->createService($key); |
123 | 123 | } |
124 | 124 | |
@@ -150,11 +150,11 @@ discard block |
||
150 | 150 | )); |
151 | 151 | |
152 | 152 | return $node; |
153 | - }else{ |
|
153 | + } else{ |
|
154 | 154 | $errorMessage = 'COULD NOT BUILD NODE FOR KEY: '.$key; |
155 | 155 | } |
156 | 156 | |
157 | - }else{ |
|
157 | + } else{ |
|
158 | 158 | $errorMessage = 'NO CONFIG FOR KEY: '.$key; |
159 | 159 | } |
160 | 160 | $this->doFireEvent(self::EVENT_CREATE_SERVICE_ERROR, array( |
@@ -198,10 +198,10 @@ discard block |
||
198 | 198 | self::HEADER_NODE => $nodeInstance |
199 | 199 | )); |
200 | 200 | return $nodeInstance; |
201 | - }else{ |
|
201 | + } else{ |
|
202 | 202 | $errorMessage = 'BUILDER RETURNED NO OBJECT FOR NODE-TYPE: '.$nodeName; |
203 | 203 | } |
204 | - }else{ |
|
204 | + } else{ |
|
205 | 205 | $errorMessage = 'NO BUILDER FOUND FOR NODE-TYPE: '.$nodeName; |
206 | 206 | } |
207 | 207 |
@@ -36,7 +36,7 @@ |
||
36 | 36 | public function callService(\PEIP\INF\Message\Message $message){ |
37 | 37 | if(is_callable($this->serviceCallable)){ |
38 | 38 | $res = call_user_func_array($this->serviceCallable, $message->getContent()); |
39 | - }elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){ |
|
39 | + } elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){ |
|
40 | 40 | $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent()); |
41 | 41 | } |
42 | 42 | return $res; |
@@ -104,7 +104,7 @@ discard block |
||
104 | 104 | $listners = $this->doGetListeners(); |
105 | 105 | if (!$this->hadListeners($name, $object)){ |
106 | 106 | $res = false; |
107 | - }else{ |
|
107 | + } else{ |
|
108 | 108 | $listners = $this->doGetListeners(); |
109 | 109 | $res = (boolean) count($listners[$object][$name]); |
110 | 110 | } |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | foreach($listeners as $listener){ |
212 | 212 | if($listener instanceof \PEIP\INF\Handler\Handler){ |
213 | 213 | $listener->handle($subject); |
214 | - }elseif(is_callable($listener)){ |
|
214 | + } elseif(is_callable($listener)){ |
|
215 | 215 | call_user_func($listener, $subject); |
216 | 216 | } |
217 | 217 | } |
@@ -46,10 +46,10 @@ |
||
46 | 46 | if($this->hasListeners($name, $object->getContent())){ |
47 | 47 | return self::doNotify($this->getListeners($name, $object->getContent()), $object); |
48 | 48 | } |
49 | - }else{ |
|
49 | + } else{ |
|
50 | 50 | throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject'); |
51 | 51 | } |
52 | - }else{ |
|
52 | + } else{ |
|
53 | 53 | throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event'); |
54 | 54 | } |
55 | 55 | } |
@@ -22,7 +22,7 @@ |
||
22 | 22 | $name = is_object($name) ? get_class($name) : (string)$name; |
23 | 23 | if(Test::assertClassOrInterfaceExists($name)){ |
24 | 24 | parent::connect($name, $listener); |
25 | - }else{ |
|
25 | + } else{ |
|
26 | 26 | throw new \InvalidArgumentException($name." is not an Class nor Interface"); |
27 | 27 | } |
28 | 28 | } |
@@ -60,11 +60,11 @@ |
||
60 | 60 | $message = NULL; |
61 | 61 | if($timeout == 0){ |
62 | 62 | $message = $this->getMessage(); |
63 | - }elseif($timeout < 0){ |
|
63 | + } elseif($timeout < 0){ |
|
64 | 64 | while(!$message = $this->getMessage()){ |
65 | 65 | |
66 | 66 | } |
67 | - }else{ |
|
67 | + } else{ |
|
68 | 68 | $time = time() + $timeout; |
69 | 69 | while(($time > time()) && !$message = $this->getMessage()){ |
70 | 70 |