111

skadefro · skadefro · commit 6f806dcf21bc · 2020-06-30T15:27:15.000+02:00
diff --git a/OpenFlow/src/amqpwrapper.ts b/OpenFlow/src/amqpwrapper.ts
@@ -241,6 +241,7 @@ export class amqpwrapper {
         }, { noAck: false });
         q.consumerTag = consumeresult.consumerTag;
         this.queues[q.queue] = q;
+        this.checkQueue(q.queue);
         return q.queue;
     }
     async AddExchangeConsumer(exchange: string, algorithm: string, routingkey: string, ExchangeOptions: any, jwt: string, callback: QueueOnMessage): Promise<void> {
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.0.20
+1.0.21

Original file line number	Diff line number	Diff line change
`@@ -241,6 +241,7 @@ export class amqpwrapper {`
`241`	`241`	`}, { noAck: false });`
`242`	`242`	`q.consumerTag = consumeresult.consumerTag;`
`243`	`243`	`this.queues[q.queue] = q;`
	`244`	`+ this.checkQueue(q.queue);`
`244`	`245`	`return q.queue;`
`245`	`246`	`}`
`246`	`247`	`async AddExchangeConsumer(exchange: string, algorithm: string, routingkey: string, ExchangeOptions: any, jwt: string, callback: QueueOnMessage): Promise<void> {`