Passed
Push — master ( da51a9...a72f89 )
by frey
04:15
created
src/Queue/CMQQueue.php 1 patch
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -124,11 +124,11 @@  discard block
 block discarded – undo
124 124
         if ($driver instanceof Topic) {
125 125
             switch ($this->topicOptions['filter']) {
126 126
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
127
-                    return retry(3, function () use ($driver, $message, $queue) {
127
+                    return retry(3, function() use ($driver, $message, $queue) {
128 128
                         return $driver->publish_message($message->msgBody, explode(',', $queue), null);
129 129
                     });
130 130
                 case self::CMQ_TOPIC_ROUTING_FILTER_NAME:
131
-                    return retry(3, function () use ($driver, $message, $queue) {
131
+                    return retry(3, function() use ($driver, $message, $queue) {
132 132
                         $driver->publish_message($message->msgBody, [], $queue);
133 133
                     });
134 134
                 default:
@@ -138,7 +138,7 @@  discard block
 block discarded – undo
138 138
             }
139 139
         }
140 140
 
141
-        return retry(3, function () use ($driver, $message, $options) {
141
+        return retry(3, function() use ($driver, $message, $options) {
142 142
             return $driver->send_message($message, Arr::get($options, 'delay', 0));
143 143
         });
144 144
     }
Please login to merge, or discard this patch.