CMProductions / queues

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

Spacing +6 added lines, -6 removed lines

@@ -43,16 +43,16 @@ 
         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(TimeoutReaderException $e) {
+            } catch (TimeoutReaderException $e) {
                 break;
             }
         }
@@ -64,8 +64,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);
             }
         }

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

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
                 'TopicArn' => $this->topicArn,
                 'Message' => json_encode($message),
             ]);
-        } catch(\Exception $e) {
+        } catch (\Exception $e) {
             $this->logger->error('Error writing messages', ['exception' => $e]);
             throw new WriterException($e->getMessage(), $e->getCode());
         }

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

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      */
     public static function create($region)
     {
-        $sqs = SqsClient::factory(['region' => $region, 'version' => '2012-11-05',]);
+        $sqs = SqsClient::factory(['region' => $region, 'version' => '2012-11-05', ]);
         $sns = SnsClient::factory(['region' => $region, 'version' => '2010-03-31']);
 
         return new self($sqs, $sns);

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

Spacing +4 added lines, -4 removed lines

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