File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ class RabbitMQQueue extends Queue implements QueueContract
2525 protected $ declaredExchanges = [];
2626
2727 protected $ declareBindQueue ;
28- protected $ declaredBindQueue = [];
28+ protected $ declaredQueues = [];
2929
3030 protected $ defaultQueue ;
3131 protected $ configQueue ;
@@ -187,8 +187,8 @@ private function declareQueue($name)
187187 );
188188 }
189189
190- if ($ this ->declareBindQueue && ! in_array ($ name , $ this ->declaredBindQueue )) {
191- $ this ->declaredBindQueue [] = $ name ;
190+ if ($ this ->declareBindQueue && ! in_array ($ name , $ this ->declaredQueues )) {
191+ $ this ->declaredQueues [] = $ name ;
192192 // declare queue
193193 $ this ->channel ->queue_declare (
194194 $ name ,
You can’t perform that action at this time.
0 commit comments