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