Merge pull request #335 from urossmolnik/amqp_unreturned_promise

Fix a warning of unreturned Promise in amqp transport connect code
moleculerjs · Jul 20, 2018 · 6e64a20 · 6e64a20
2 parents 44cf56a + 3afa39c
commit 6e64a20
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/transporters/amqp.js b/src/transporters/amqp.js
@@ -130,7 +130,6 @@ class AmqpTransporter extends Transporter {
 						.createChannel()
 						.then((channel) => {
 							this.channel = channel;
-							this.onConnected().then(resolve);
 							this.logger.info("AMQP channel is created.");
 
 							channel.prefetch(this.opts.prefetch);
@@ -157,7 +156,10 @@ class AmqpTransporter extends Transporter {
 								.on("return", (msg) => {
 									this.logger.warn("AMQP channel returned a message.", msg);
 								});
+
+							return this.onConnected();
 						})
+						.then(resolve)
 						.catch((err) => {
 							/* istanbul ignore next*/
 							this.logger.error("AMQP failed to create channel.");