@@ -30,8 +30,7 @@ discard block |
||
30 | 30 | throw new \Exception('loading XML failed'); |
31 | 31 | } |
32 | 32 | |
33 | - } |
|
34 | - catch (\Exception $e) { |
|
33 | + } catch (\Exception $e) { |
|
35 | 34 | return false; |
36 | 35 | } |
37 | 36 | |
@@ -65,7 +64,7 @@ discard block |
||
65 | 64 | ) |
66 | 65 | ); |
67 | 66 | } |
68 | - }else { |
|
67 | + } else { |
|
69 | 68 | $array[$name] = array(); |
70 | 69 | } |
71 | 70 | $array[$name][] = $res; |
@@ -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 |
@@ -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 | } |
@@ -53,7 +53,7 @@ |
||
53 | 53 | * @param $observer |
54 | 54 | * @return |
55 | 55 | */ |
56 | - public function addObserver(\PEIP\INF\Event\Observer $observer){ |
|
56 | + public function addObserver(\PEIP\INF\Event\Observer $observer) { |
|
57 | 57 | $this->observers[] = $observer; |
58 | 58 | } |
59 | 59 |
@@ -114,8 +114,7 @@ |
||
114 | 114 | $this->send($content); |
115 | 115 | try { |
116 | 116 | $res = $this->receive(); |
117 | - } |
|
118 | - catch (\Exception $e) { |
|
117 | + } catch (\Exception $e) { |
|
119 | 118 | return NULL; |
120 | 119 | } |
121 | 120 | return $res; |
@@ -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 | } |