fix(client): only listen for Session.Mapped once during connect

noodlefrenzy · Aug 7, 2015 · 0cfd687 · 0cfd687
1 parent c4e3e8c
commit 0cfd687
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/amqp_client.js b/lib/amqp_client.js
@@ -139,7 +139,7 @@ AMQPClient.prototype.connect = function(url) {
         self._session = self._newSession(c);
       }
 
-      self._session.on(Session.Mapped, function(s) {
+      self._session.once(Session.Mapped, function(s) {
         debug('mapped');
         resolve(self);
       });