CMProductions / queues

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

Spacing +6 added lines, -6 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);
         }
     }
@@ -119,7 +119,7 @@ 
         $messages = isset($result['Messages']) ? $result['Messages'] : [];
         foreach ($messages as $message) {
             $response = $this->messageHandler->handleMessage($message);
-            if(is_null($response) || !is_bool($response) || $response) {
+            if (is_null($response) || !is_bool($response) || $response) {
                 $this->sqs->deleteMessage(['QueueUrl' => $this->queueUrl, 'ReceiptHandle' => $message['ReceiptHandle']]);
             }
         }

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

Spacing +3 added lines, -3 removed lines

@@ -42,7 +42,7 @@ 
             throw new ReaderException("Handling a message with no callback set");
         }
 
-        try{
+        try {
 
             if (!isset($message['Body'])) {
                 throw new InvalidJSONMessageException('Undefined index key Body: ' . print_r($message, true));
@@ -56,8 +56,8 @@ 
 
             return call_user_func($this->callback, $this->jsonMessageFactory->create($body['Message']));
 
-        } catch(InvalidJSONMessageException $e) {
-            throw new ParseMessageException(json_encode($message),0, $e);
+        } catch (InvalidJSONMessageException $e) {
+            throw new ParseMessageException(json_encode($message), 0, $e);
         }
     }
 

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

Spacing +2 added lines, -2 removed lines

@@ -42,10 +42,10 @@
         try {
             $task = $this->jsonMessageFactory->create($message->body);
             $response = call_user_func($this->callback, $task);
-            if(is_null($response) || !is_bool($response) || $response) {
+            if (is_null($response) || !is_bool($response) || $response) {
                 $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);
         }
     }