Added pass through for amqplib 'blocked' and 'unblocked' events to allow registration of handlers.

manjbhachu · manjbhachu · commit ec6ecfec95d9 · 2014-07-21T18:45:21.000+01:00
diff --git a/lib/sockets.js b/lib/sockets.js
@@ -37,11 +37,12 @@ function Context(url) {
   EventEmitter.call(this);
   var self = this;
   var onError = errorLater(this);
-  var onClose = this.emit.bind(this, 'close');
   var c = this._connection = amqp.connect(url);
   c.then(function(conn) {
     conn.on('error', onError);
-    conn.on('close', onClose);
+    ['close', 'blocked', 'unblocked'].forEach(function(ev) {
+      conn.on(ev, self.emit.bind(self, ev));
+    });
   });
   c.then(this.emit.bind(this, 'ready')).then(null, onError);
 };
