@@ -124,11 +124,11 @@ discard block |
||
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 |
||
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 | } |