fix: ensure consumer tag is generated on creation of consumer

microfleet · Mar 25, 2022 · 18464e8 · 18464e8
1 parent fd27b86
commit 18464e8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/packages/amqp-coffee/src/lib/consumer.ts b/packages/amqp-coffee/src/lib/consumer.ts
@@ -76,6 +76,8 @@ export class Consumer extends Channel {
     this._basicConsumePreflight = this._basicConsumePreflight.bind(this)
     this._consumerStateOpenPreflight = this._consumerStateOpenPreflight.bind(this)
     this._onConsumeError = this._onConsumeError.bind(this)
+
+    this.consumerTag = this.generateConsumerTag()
   }
 
   public async ready(): Promise<void> {
@@ -89,7 +91,6 @@ export class Consumer extends Channel {
   }
 
   public async consume(queueName: string, messageHandler: MessageHandler, options: ConsumeHandlerOpts = {}): Promise<BasicConsumeResponse> {
-    this.consumerTag = this.generateConsumerTag()
     debug(2, () => `Consuming ${queueName} on channel ${this.channel}`)
     this.consumerState = CONSUMER_STATES.CONSUMER_STATE_OPENING