CMProductions / queues

src/Cmp/Queues/Infrastructure/AWS/v20121105/Queue/QueueReader.php

Spacing +5 added lines, -5 removed lines

@@ -68,20 +68,20 @@
      * @throws ReaderException
      * @throws TimeoutReaderException
      */
-    public function read(callable $callback, $timeout=0)
+    public function read(callable $callback, $timeout = 0)
     {
         $this->messageHandler->setCallback($callback);
 
         try {
             $this->consume($timeout);
-        } catch(ParseMessageException $e){
+        } catch (ParseMessageException $e) {
             throw $e;
-        } catch(GracefulStopException $e) {
+        } catch (GracefulStopException $e) {
             $this->logger->info("Gracefully stopping the AWS queue reader", ["exception" => $e]);
             throw $e;
-        } catch(TimeoutReaderException $e) {
+        } catch (TimeoutReaderException $e) {
             throw $e;
-        } catch(\Exception $e) {
+        } catch (\Exception $e) {
             throw new ReaderException("Error occurred while reading", 0, $e);
         }
     }

src/Cmp/Queues/Infrastructure/AmqpLib/v26/RabbitMQ/Queue/MessageHandler.php

Spacing +2 added lines, -2 removed lines

@@ -43,9 +43,9 @@
             $task = $this->jsonMessageFactory->create($message->body);
             call_user_func($this->callback, $task);
             $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
-        } catch(InvalidJSONMessageException $e) {
+        } catch (InvalidJSONMessageException $e) {
             throw new ParseMessageException(json_encode($message->getBody()), 0, $e);
-        } catch(Exception $e) {
+        } catch (Exception $e) {
             throw $e;
         }
     }

src/Cmp/Queues/Infrastructure/AWS/v20121105/Queue/MessageHandler.php

Spacing +5 added lines, -5 removed lines

@@ -42,10 +42,10 @@ 
         }
 
         if (!isset($message['Body'])) {
-            throw new ParseMessageException(json_encode($message),0, 'Undefined index key Body: ' . print_r($message, true));
+            throw new ParseMessageException(json_encode($message), 0, 'Undefined index key Body: ' . print_r($message, true));
         }
 
-        try{
+        try {
 
             $body = json_decode($message['Body'], true);
 
@@ -55,9 +55,9 @@ 
 
             call_user_func($this->callback, $this->jsonMessageFactory->create($body['Message']));
 
-        } catch(InvalidJSONMessageException $e) {
-            throw new ParseMessageException(json_encode($message),0, $e);
-        } catch(Exception $e) {
+        } catch (InvalidJSONMessageException $e) {
+            throw new ParseMessageException(json_encode($message), 0, $e);
+        } catch (Exception $e) {
             throw $e;
         }
     }

src/Cmp/Queues/Domain/Queue/QueueReader.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      * @return void
      * @throws ReaderException
      */
-    public function read(callable $callback, $timeout=0);
+    public function read(callable $callback, $timeout = 0);
 
     /**
      * Deletes all messages from the queue

src/Cmp/Queues/Domain/Event/Subscriber.php

Spacing +8 added lines, -8 removed lines

@@ -50,16 +50,16 @@ 
      * @throws DomainEventException
      * @throws \Cmp\Queues\Domain\Queue\Exception\ReaderException
      */
-    public function start($timeout=0)
+    public function start($timeout = 0)
     {
         $this->checkHasSubscriptors();
 
-        while(true) {
+        while (true) {
             try {
                 $this->queueReader->read(array($this, 'notify'), $timeout);
-            } catch(TimeoutReaderException $e) {
+            } catch (TimeoutReaderException $e) {
                 break;
-            } catch(GracefulStopException $e) {
+            } catch (GracefulStopException $e) {
                 break;
             }
         }
@@ -70,7 +70,7 @@ 
      * @throws DomainEventException
      * @throws \Cmp\Queues\Domain\Queue\Exception\ReaderException
      */
-    public function batch($timeout=0)
+    public function batch($timeout = 0)
     {
         $this->checkHasSubscriptors();
 
@@ -83,8 +83,8 @@ 
     public function notify(DomainEvent $domainEvent)
     {
         $this->logger->debug('Domain Event received, notifying subscribers');
-        foreach($this->subscriptors as $subscriptor) {
-            if($subscriptor->isSubscribed($domainEvent)) {
+        foreach ($this->subscriptors as $subscriptor) {
+            if ($subscriptor->isSubscribed($domainEvent)) {
                 $subscriptor->notify($domainEvent);
             }
         }
@@ -103,7 +103,7 @@ 
      */
     private function checkHasSubscriptors()
     {
-        if(empty($this->getSubscriptors())) {
+        if (empty($this->getSubscriptors())) {
             throw new DomainEventException('You must add at least 1 EventSubscriptor in order to publish start reading from queue.');
         }
     }