We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9936560 commit 4caac99Copy full SHA for 4caac99
1 file changed
OpenFlowNodeRED/src/nodered/nodes/amqp_nodes.ts
@@ -454,10 +454,10 @@ export class amqp_exchange_node {
454
}
455
456
async onclose(removed: boolean, done: any) {
457
- // if (!NoderedUtil.IsNullEmpty(this.localqueue) && removed) {
458
- NoderedUtil.CloseQueue(this.websocket(), this.localqueue);
459
- this.localqueue = "";
460
- // }
+ if (!NoderedUtil.IsNullEmpty(this.localqueue)) { // && removed
+ NoderedUtil.CloseQueue(this.websocket(), this.localqueue);
+ this.localqueue = "";
+ }
461
this.websocket().events.removeListener("onsignedin", this._onsignedin);
462
this.websocket().events.removeListener("onclose", this._onsocketclose);
463
if (done != null) done();
0 commit comments