diff --git a/lib/client.js b/lib/client.js index a0ba5b6..5680a93 100644 --- a/lib/client.js +++ b/lib/client.js @@ -1,7 +1,7 @@ var net = require('net'), tls = require('tls'), eventParser = require('../lib/eventParser.js'), - pubsub = require('event-pubsub'), + Pubsub = require('event-pubsub'), Message = require('js-message'), fs = require('fs'), Queue = require('js-queue'); @@ -16,7 +16,7 @@ function init(config,log){ log : log, retriesRemaining:config.maxRetries||0 } - new pubsub(client); + new Pubsub(client); return client; } diff --git a/lib/socketServer.js b/lib/socketServer.js index d62219b..076efb9 100644 --- a/lib/socketServer.js +++ b/lib/socketServer.js @@ -3,7 +3,7 @@ var net = require('net'), fs = require('fs'), dgram = require('dgram'), eventParser = require('../lib/eventParser.js'), - pubsub = require('event-pubsub'), + Pubsub = require('event-pubsub'), Message = require('js-message'); function emit(socket, type, data){ @@ -327,7 +327,7 @@ function init(path,config,log,port){ } }; - new pubsub(server); + new Pubsub(server); server.on( 'close', diff --git a/node-ipc.js b/node-ipc.js index 74db786..97567a7 100644 --- a/node-ipc.js +++ b/node-ipc.js @@ -2,7 +2,6 @@ var os = require('os'), dns = require('dns'), util = require('util'), colors = require('colors'), - pubsub = require('event-pubsub'), eventParser = require('./lib/eventParser.js'), Client = require('./lib/client.js'), Server = require('./lib/socketServer.js');