CMProductions / queues

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

Spacing +3 added lines, -3 removed lines

@@ -25,12 +25,12 @@
      * @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;
             }
         }