diff --git a/lib/client.js b/lib/client.js index 563606f..a5326c1 100644 --- a/lib/client.js +++ b/lib/client.js @@ -22,6 +22,10 @@ var Client = function(config) { this.queryQueue = []; this.password = config.password || defaults.password; this.encoding = 'utf8'; + var self = this; + this.connection.on('notify', function(msg) { + self.emit('notify', msg); + }) }; sys.inherits(Client, EventEmitter);