Merge pull request #1168 from moleculerjs/issue-1167

Fix #1167
moleculerjs · Dec 18, 2022 · 3e8fcef · 3e8fcef
2 parents 2b17e23 + 7ed2c35
commit 3e8fcef
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/transporters/amqp.js b/src/transporters/amqp.js
@@ -429,6 +429,8 @@ class AmqpTransporter extends Transporter {
 	 * @memberof AmqpTransporter
 	 */
 	subscribeBalancedRequest(action) {
+		if (!this.channel) return;
+
 		const queue = `${this.prefix}.${PACKET_REQUEST}B.${action}`;
 		return this.channel
 			.assertQueue(queue, this._getQueueOptions(PACKET_REQUEST, true))
@@ -449,6 +451,8 @@ class AmqpTransporter extends Transporter {
 	 * @memberof AmqpTransporter
 	 */
 	subscribeBalancedEvent(event, group) {
+		if (!this.channel) return;
+
 		const queue = `${this.prefix}.${PACKET_EVENT}B.${group}.${event}`;
 		return this.channel
 			.assertQueue(queue, this._getQueueOptions(PACKET_EVENT + "LB", true))