Skip to content

Commit b1ba968

Browse files
committed
toggle autodelete for openflow exchange
1 parent a5c6a72 commit b1ba968

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

OpenFlow/src/amqpwrapper.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ export class amqpwrapper extends events.EventEmitter {
349349
}
350350
// q.ExchangeOptions = new Object((ExchangeOptions != null ? ExchangeOptions : this.AssertExchangeOptions));
351351
q.ExchangeOptions = Object.assign({}, (ExchangeOptions != null ? ExchangeOptions : this.AssertExchangeOptions));
352-
if (exchange != Config.amqp_dlx) q.ExchangeOptions.autoDelete = true;
352+
if (exchange != Config.amqp_dlx && exchange != "openflow") q.ExchangeOptions.autoDelete = true;
353353
q.exchange = exchange; q.algorithm = algorithm; q.routingkey = routingkey; q.callback = callback;
354354
const _ok = await this.channel.assertExchange(q.exchange, q.algorithm, q.ExchangeOptions);
355355
let AssertQueueOptions = null;

0 commit comments

Comments
 (0)