CMProductions / queues

src/Cmp/Queues/Domain/Task/Consumer.php

Spacing +4 added lines, -4 removed lines

@@ -26,14 +26,14 @@
      * @param callable $callback Callable that'll be invoked when a message is received
      * @param int      $timeout (optional) If specified, the process will block a max of $timeout seconds. Indefinitely if 0
      */
-    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(TimeoutReaderException $e) {
+            } catch (TimeoutReaderException $e) {
                 break;
-            } catch(GracefulStopException $e) {
+            } catch (GracefulStopException $e) {
                 break;
             }
         }

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

Spacing +6 added lines, -6 removed lines

@@ -97,20 +97,20 @@ 
      * @throws TimeoutReaderException
      * @throws GracefulStopException
      */
-    public function read(callable $callback, $timeout=0)
+    public function read(callable $callback, $timeout = 0)
     {
         $this->initialize();
         $this->messageHandler->setCallback($callback);
 
         try {
             $this->consume($timeout);
-        } catch(GracefulStopException $e) {
+        } catch (GracefulStopException $e) {
             $this->stopConsuming();
             throw  new GracefulStopException("Graceful exception", 0, $e);
-        } catch(AMQPTimeoutException $e) {
+        } catch (AMQPTimeoutException $e) {
             $this->stopConsuming();
             throw new TimeoutReaderException("Timed out at $timeout seconds while reading.", 0, $e);
-        } catch(\Exception $e) {
+        } catch (\Exception $e) {
             $this->stopConsuming();
             throw new ReaderException("Error occurred while reading", 0, $e);
         }
@@ -169,7 +169,7 @@ 
     protected function consume($timeout)
     {
         if ($this->consumerTag === '') {
-            $this->logger->debug('Waiting for messages on queue:'.$this->queueConfig->getName());
+            $this->logger->debug('Waiting for messages on queue:' . $this->queueConfig->getName());
             $this->consumerTag = $this->channel->basic_consume(
                 $this->queueConfig->getName(),
                 '',
@@ -210,7 +210,7 @@ 
         if ($this->consumerTag) {
             try {
                 $this->channel->basic_cancel($this->consumerTag);
-            } catch(\Exception $e) {
+            } catch (\Exception $e) {
             }
 
             $this->consumerTag = '';