@@ -51,7 +51,7 @@ discard block |
||
51 | 51 | $constructor = isset($config["constructor"]) ? (string)$config["constructor"] : ""; |
52 | 52 | if ($constructor != '' && Test::assertMethod($cls, $constructor)) { |
53 | 53 | $service = call_user_func_array(array($cls, $constructor), $arguments); |
54 | - } else { |
|
54 | + }else { |
|
55 | 55 | $service = self::build($cls, $arguments); |
56 | 56 | } |
57 | 57 | } catch (\Exception $e) { |
@@ -97,7 +97,7 @@ discard block |
||
97 | 97 | if ($entry->getName() == 'value') { |
98 | 98 | if ($entry['key']) { |
99 | 99 | $arg[(string)$entry['key']] = (string)$entry; |
100 | - } else { |
|
100 | + }else { |
|
101 | 101 | $arg[] = (string)$entry; |
102 | 102 | } |
103 | 103 | } elseif ($entry->getName() == 'service') { |
@@ -129,7 +129,7 @@ discard block |
||
129 | 129 | public static function buildAndModify(array $config, $arguments, $defaultClass = "") { |
130 | 130 | if ((isset($config["class"]) && "" != (string)$config["class"]) || $defaultClass !== "") { |
131 | 131 | $service = ServiceFactory::doBuild($config, $arguments, $defaultClass); |
132 | - } else { |
|
132 | + }else { |
|
133 | 133 | throw new \RuntimeException('Could not create Service. no class or reference given.'); |
134 | 134 | } |
135 | 135 | if (isset($config["ref_property"])) { |
@@ -117,7 +117,7 @@ discard block |
||
117 | 117 | |
118 | 118 | if ($this->hasService($key)) { |
119 | 119 | $service = $this->getService($key); |
120 | - } else { |
|
120 | + }else { |
|
121 | 121 | $service = $this->createService($key); |
122 | 122 | } |
123 | 123 | |
@@ -149,11 +149,11 @@ discard block |
||
149 | 149 | )); |
150 | 150 | |
151 | 151 | return $node; |
152 | - } else { |
|
152 | + }else { |
|
153 | 153 | $errorMessage = 'COULD NOT BUILD NODE FOR KEY: '.$key; |
154 | 154 | } |
155 | 155 | |
156 | - } else { |
|
156 | + }else { |
|
157 | 157 | $errorMessage = 'NO CONFIG FOR KEY: '.$key; |
158 | 158 | } |
159 | 159 | $this->doFireEvent(self::EVENT_CREATE_SERVICE_ERROR, array( |
@@ -197,10 +197,10 @@ discard block |
||
197 | 197 | self::HEADER_NODE => $nodeInstance |
198 | 198 | )); |
199 | 199 | return $nodeInstance; |
200 | - } else { |
|
200 | + }else { |
|
201 | 201 | $errorMessage = 'BUILDER RETURNED NO OBJECT FOR NODE-TYPE: '.$nodeName; |
202 | 202 | } |
203 | - } else { |
|
203 | + }else { |
|
204 | 204 | $errorMessage = 'NO BUILDER FOUND FOR NODE-TYPE: '.$nodeName; |
205 | 205 | } |
206 | 206 |
@@ -64,7 +64,7 @@ |
||
64 | 64 | ) |
65 | 65 | ); |
66 | 66 | } |
67 | - } else { |
|
67 | + }else { |
|
68 | 68 | $array[$name] = array(); |
69 | 69 | } |
70 | 70 | $array[$name][] = $res; |
@@ -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 | //} |
@@ -77,7 +77,7 @@ |
||
77 | 77 | $this->inputChannel = $inputChannel; |
78 | 78 | if ($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel) { |
79 | 79 | $this->inputChannel->subscribe($this); |
80 | - }else { |
|
80 | + } else { |
|
81 | 81 | $this->unwrapEvents = true; |
82 | 82 | $this->inputChannel->connect('postSend', $this); |
83 | 83 | } |
@@ -52,7 +52,7 @@ |
||
52 | 52 | while (!$message = $this->getMessage()) { |
53 | 53 | |
54 | 54 | } |
55 | - } else { |
|
55 | + }else { |
|
56 | 56 | $time = time() + $timeout; |
57 | 57 | while (($time > time()) && !$message = $this->getMessage()) { |
58 | 58 |
@@ -64,7 +64,7 @@ |
||
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 |
@@ -54,7 +54,7 @@ |
||
54 | 54 | protected function doSend(\PEIP\INF\Message\Message $message) { |
55 | 55 | if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) { |
56 | 56 | $this->queue->insert($message, $message->getHeader($this->priorityHeader)); |
57 | - } else { |
|
57 | + }else { |
|
58 | 58 | throw new \Exception('Not implemented yet.'); |
59 | 59 | } |
60 | 60 | } |
@@ -56,11 +56,11 @@ |
||
56 | 56 | if ($static && !$reflectionFunc->isStatic()) { |
57 | 57 | throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.'); |
58 | 58 | } |
59 | - } else { |
|
59 | + }else { |
|
60 | 60 | $reflectionFunc = new \ReflectionFunction($this->callable); |
61 | 61 | } |
62 | 62 | $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters(); |
63 | - } else { |
|
63 | + }else { |
|
64 | 64 | throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable'); |
65 | 65 | } |
66 | 66 | } |