diff --git a/index.js b/index.js
index <HASH>..<HASH> 100644
--- a/index.js
+++ b/index.js
@@ -131,6 +131,7 @@ var sig = module.exports = function(messenger, opts) {
   // initialise the data event name
   var dataEvent = (opts || {}).dataEvent || 'data';
   var openEvent = (opts || {}).openEvent || 'open';
+  var closeEvent = (opts || {}).closeEvent || 'close';
   var writeMethod = (opts || {}).writeMethod || 'write';
   var closeMethod = (opts || {}).closeMethod || 'close';
   var connected = false;
@@ -169,6 +170,10 @@ var sig = module.exports = function(messenger, opts) {
       signaller.emit('open');
       signaller.emit('connected');
     });
+
+    messenger.on(closeEvent, function() {
+      signaller.emit('disconnected');
+    });
   }
 
   function connectToPrimus(url) {
Primus close event generates disconnected event, ref #<I>