CMProductions / queues

src/Infrastructure/AmqpLib/v26/RabbitMQ/Queue/QueueReader.php

Spacing +2 added lines, -2 removed lines

@@ -94,7 +94,7 @@ 
      * @param int $timeout
      * @throws ReaderException
      */
-    public function read(callable $callback, $timeout=0)
+    public function read(callable $callback, $timeout = 0)
     {
         $this->initialize();
         $this->messageHandler->setCallback($callback);
@@ -106,7 +106,7 @@ 
      */
     protected function initialize()
     {
-        if($this->channel) {
+        if ($this->channel) {
             return;
         }
         $this->logger->info('Connecting to RabbitMQ');

src/Domain/Event/Subscriber.php

Spacing +6 added lines, -6 removed lines

@@ -42,15 +42,15 @@ 
         return $this;
     }
 
-    public function start($timeout=0)
+    public function start($timeout = 0)
     {
-        if(!isset($this->subscriptors[0])) {
+        if (!isset($this->subscriptors[0])) {
             throw new DomainEventException('You must add at least 1 EventSubscriptor in order to publish start reading from queue.');
         }
-        while(true) {
+        while (true) {
             try {
                 $this->queueReader->read(array($this, 'notify'), $timeout);
-            } catch(\Exception $e) {
+            } catch (\Exception $e) {
                 break;
             }
         }
@@ -62,8 +62,8 @@ 
     public function notify(DomainEvent $domainEvent)
     {
         $this->logger->info('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);
             }
         }

src/Domain/Queue/QueueReader.php

Spacing +1 added lines, -1 removed lines

@@ -17,5 +17,5 @@
      * @throws ReaderException
      * @return void
      */
-    public function read(callable $callback, $timeout=0);
+    public function read(callable $callback, $timeout = 0);
 }
\ No newline at end of file

src/Domain/Task/Consumer.php

Spacing +3 added lines, -3 removed lines

@@ -19,12 +19,12 @@
         $this->queueReader = $queueReader;
     }
 
-    public function consume(callable $callback, $timeout=0)
+    public function consume(callable $callback, $timeout = 0)
     {
-        while(true) {
+        while (true) {
             try {
                 $this->queueReader->read($callback, $timeout);
-            } catch(\Exception $e) {
+            } catch (\Exception $e) {
                 break;
             }
         }