freyo / laravel-queue-cmq

src/Queue/CMQQueue.php

Spacing +3 added lines, -3 removed lines

@@ -137,12 +137,12 @@ 
             switch ($this->topicOptions['filter']) {
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 3),
-                        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', 3),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             $driver->publish_message($message->msgBody, [], $queue);
                         });
                 default:
@@ -152,7 +152,7 @@ 
             }
         }
 
-        return retry(Arr::get($this->queueOptions, 'retries', 3), function () use ($driver, $message, $options) {
+        return retry(Arr::get($this->queueOptions, 'retries', 3), function() use ($driver, $message, $options) {
             return $driver->send_message($message, Arr::get($options, 'delay', 0));
         });
     }