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