fixes noodlefrenzy#358 - the connection:opened event should be emited…

… after all operations ?
karlvlam · Mar 12, 2018 · 86ed765 · 86ed765
1 parent e61b5ff
commit 86ed765
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/amqp_client.js b/lib/amqp_client.js
@@ -169,7 +169,6 @@ AMQPClient.prototype.connect = function(url, policyOverrides) {
     self._connection = self._newConnection(connectPolicy);
     self._connection.on(Connection.Connected, function(c) {
       debug('connected');
-      self.emit(AMQPClient.ConnectionOpened);
 
       var promises = [];
 
@@ -213,10 +212,12 @@ AMQPClient.prototype.connect = function(url, policyOverrides) {
         Promise.all(promises).then(function() {
           self.emit('connected');
           resolve(self);
+          self.emit(AMQPClient.ConnectionOpened);
         }).catch(reject);
       } else {
         self.emit('connected');
         resolve(self);
+        self.emit(AMQPClient.ConnectionOpened);
       }
     });