freyo / laravel-queue-cmq

src/Queue/CMQQueue.php

Spacing +3 added lines, -3 removed lines

@@ -130,12 +130,12 @@ 
             switch ($this->topicOptions['filter']) {
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 1),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             return $driver->publish_message($message->msgBody, explode(',', $queue), null);
                         });
                 case self::CMQ_TOPIC_ROUTING_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 1),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             $driver->publish_message($message->msgBody, [], $queue);
                         });
                 default:
@@ -145,7 +145,7 @@ 
             }
         }
 
-        return retry(Arr::get($this->queueOptions, 'retries', 1), function () use ($driver, $message, $options) {
+        return retry(Arr::get($this->queueOptions, 'retries', 1), function() use ($driver, $message, $options) {
             return $driver->send_message($message, Arr::get($options, 'delay', 0));
         });
     }