Skip to content

Commit 2829215

Browse files
committed
fixed bug in getQueueFlags
1 parent dcf619e commit 2829215

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/Queue/AMQPQueue.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -288,8 +288,9 @@ protected function getQueueName($name)
288288
*/
289289
protected function getQueueFlags($queueName, $deferredQueueName = null, $deferredQueueDelay = null)
290290
{
291-
$result = ArrayUtil::arrayMapRecursive(function ($value) {
292-
return is_callable($value) ? call_user_func_array($value, func_get_args()) : $value;
291+
$args = func_get_args();
292+
$result = ArrayUtil::arrayMapRecursive(function ($value) use($args) {
293+
return is_callable($value) ? call_user_func_array($value, $args) : $value;
293294
}, $this->queueFlags);
294295

295296
$result = ArrayUtil::removeNullsRecursive($result);

0 commit comments

Comments
 (0)