We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8e55e1c commit 8e29088Copy full SHA for 8e29088
1 file changed
OpenFlow/src/amqpwrapper.ts
@@ -282,7 +282,7 @@ export class amqpwrapper extends events.EventEmitter {
282
if (NoderedUtil.IsNullUndefinded(queue)) throw new Error("queue is mandatory");
283
if (queue != null) {
284
if (Config.log_amqp) Logger.instanse.info("[AMQP] Remove queue consumer " + queue.queue + "/" + queue.consumerTag);
285
- var exc = this.exchanges.filter(x => x.queue.consumerTag == queue.consumerTag);
+ var exc = this.exchanges.filter(x => x.queue?.consumerTag == queue.consumerTag);
286
if (exc.length > 0) {
287
try {
288
this.channel.unbindQueue(exc[0].queue.queue, exc[0].exchange, exc[0].routingkey);
0 commit comments