@@ -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 | } |
@@ -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 | $store = $this->factory->build(); |
| 55 | 55 | if ($store instanceof \PEIP\INF\Data\Store) { |
| 56 | 56 | $this->setPrivateValue($namespace, $store); |
| 57 | - }else { |
|
| 57 | + } else { |
|
| 58 | 58 | throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.'); |
| 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 | } |
@@ -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 | } |