CMProductions / queues

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

Spacing +4 added lines, -4 removed lines

@@ -90,15 +90,15 @@ 
      * @throws ReaderException
      * @throws TimeoutReaderException
      */
-    public function read(callable $callback, $timeout=0)
+    public function read(callable $callback, $timeout = 0)
     {
         $this->initialize();
         $this->messageHandler->setCallback($callback);
         try {
             $this->channel->wait(null, false, $timeout);
-        } catch(AMQPTimeoutException $e) {
+        } catch (AMQPTimeoutException $e) {
             throw new TimeoutReaderException("Timed out at $timeout seconds while reading.", 0, $e);
-        } catch(\Exception $e) {
+        } catch (\Exception $e) {
             throw new ReaderException("Error occurred while reading", 0, $e);
         }
     }
@@ -108,7 +108,7 @@ 
      */
     protected function initialize()
     {
-        if($this->channel) {
+        if ($this->channel) {
             return;
         }
         $this->logger->info('Connecting to RabbitMQ');

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

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
             return new Task(
                 $taskArray['name'], $taskArray['body'], isset($taskArray['delay']) ? $taskArray['delay'] : 0
             );
-        } catch(TaskException $e) {
+        } catch (TaskException $e) {
             throw new InvalidJSONTaskException("Failed creating Task instance", 0, $e);
         }
     }