CMProductions / queues

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/QueueReader.php

Indentation +1 added lines, -1 removed lines

@@ -170,7 +170,7 @@
                         'Condition' => [
                                 'ArnEquals' => [
                                     'aws:SourceArn' => $topicArn,
-                           ],
+                            ],
                         ],
                     ],
                 ]),

Spacing +3 added lines, -3 removed lines

@@ -68,15 +68,15 @@
      * @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(TimeoutReaderException $e) {
+        } catch (TimeoutReaderException $e) {
             throw $e;
-        } catch(\Exception $e) {
+        } catch (\Exception $e) {
             throw new ReaderException("Error occurred while reading", 0, $e);
         }
     }