Skip to content

Commit f1e6fe9

Browse files
author
Ratko Rudic
committed
Bugfix: queue_declare() doesn't take array, but AMQPTable() class.
1 parent 48b620a commit f1e6fe9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ private function declareQueue($name)
231231
$this->configQueue['exclusive'],
232232
$this->configQueue['auto_delete'],
233233
false,
234-
$this->configQueue['arguments']
234+
new AMQPTable($this->configQueue['arguments'])
235235
);
236236

237237
// bind queue to the exchange

0 commit comments

Comments
 (0)