Hi,

Is this module working correctly with NodeJS? My NodeJS looks to be setup correctly, i am receiving broadcast messages fine and not getting any errors. Is looks like

.on('message-published', function (message, i)

is never called?

Here are some logs from terminal

engine intercepting request for path "/socket.io/" +8s
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270767-27" +0ms
  engine handshaking client "Le5qQhQgFYEb0saoAAAC" +1ms
  engine:socket sending packet "open" ({"sid":"Le5qQhQgFYEb0saoAAAC","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}) +0ms
  engine:polling setting request +0ms
  engine:socket flushing buffer to transport +0ms
  engine:polling writing "	�0{"sid":"Le5qQhQgFYEb0saoAAAC","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}" +0ms
  engine:socket executing batch send callback +1ms
  socket.io:server incoming connection with id Le5qQhQgFYEb0saoAAAC +1.8m
  socket.io:client connecting to namespace / +1s
  socket.io:namespace adding socket to nsp / +1.8m
  socket.io:socket socket connected - writing packet +1s
  socket.io:socket joining room Le5qQhQgFYEb0saoAAAC +0ms
  socket.io:client writing packet {"type":0,"nsp":"/"} +0ms
  socket.io-parser encoding packet {"type":0,"nsp":"/"} +1.7m
  socket.io-parser encoded {"type":0,"nsp":"/"} as 0 +0ms
  engine:socket sending packet "message" (0) +1ms
  socket.io:socket joined room Le5qQhQgFYEb0saoAAAC +1ms
  engine intercepting request for path "/socket.io/" +4ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270773-28&sid=Le5qQhQgFYEb0saoAAAC" +0ms
  engine setting new request for existing client +2ms
  engine:polling setting request +1ms
  engine:socket flushing buffer to transport +0ms
  engine:polling writing "�40" +0ms
  engine:socket executing batch send callback +1ms
  engine intercepting request for path "/socket.io/" +9ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270783-30&sid=Le5qQhQgFYEb0saoAAAC" +1ms
  engine setting new request for existing client +0ms
  engine:polling setting request +0ms
  engine intercepting request for path "/socket.io/" +2ms
  engine handling "OPTIONS" http request "/socket.io/?EIO=3&transport=polling&t=1419191270782-29&sid=Le5qQhQgFYEb0saoAAAC" +1ms
  engine setting new request for existing client +0ms
  engine intercepting request for path "/socket.io/" +5ms
  engine handling "POST" http request "/socket.io/?EIO=3&transport=polling&t=1419191270782-29&sid=Le5qQhQgFYEb0saoAAAC" +0ms
  engine setting new request for existing client +0ms
  engine:polling received "�42["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]" +1ms
  engine:socket packet +0ms
  socket.io-parser decoded 2["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] as {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +27ms
  socket.io:socket got packet {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +28ms
  socket.io:socket emitting event ["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] +0ms
Authenticating client with key "5449114a002aa956cc51ade10c1a8f1a"
Reusing existing authentication data for key: 5449114a002aa956cc51ade10c1a8f1a , client id: Le5qQhQgFYEb0saoAAAC
{ SJHuQncovQQBEDe8AAAA: 
   { nsp: 
      { name: '/',
        server: [Object],
        sockets: [Object],
        connected: [Object],
        fns: [],
        ids: 0,
        acks: {},
        adapter: [Object],
        _events: [Object] },
     server: 
      { nsps: [Object],
        _path: '/socket.io',
        _serveClient: true,
        _adapter: [Function: Adapter],
        _origins: '*:*',
        sockets: [Object],
        eio: [Object],
        httpServer: [Object],
        engine: [Object] },
     adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
     id: 'SJHuQncovQQBEDe8AAAA',
     client: 
      { server: [Object],
        conn: [Object],
        encoder: {},
        decoder: [Object],
        id: 'SJHuQncovQQBEDe8AAAA',
        request: [Object],
        onclose: [Function],
        ondata: [Function],
        onerror: [Function],
        ondecoded: [Function],
        sockets: [Object],
        nsps: [Object],
        connectBuffer: [] },
     conn: 
      { id: 'SJHuQncovQQBEDe8AAAA',
        server: [Object],
        upgraded: true,
        readyState: 'open',
        writeBuffer: [],
        packetsFn: [],
        sentCallbackFn: [],
        request: [Object],
        remoteAddress: '127.0.0.1',
        checkIntervalTimer: null,
        upgradeTimeoutTimer: [Object],
        pingTimeoutTimer: [Object],
        transport: [Object],
        _events: [Object] },
     rooms: [ 'SJHuQncovQQBEDe8AAAA' ],
     acks: {},
     connected: true,
     disconnected: false,
     handshake: 
      { headers: [Object],
        time: 'Sun Dec 21 2014 19:46:05 GMT+0000 (GMT)',
        address: '127.0.0.1',
        xdomain: true,
        secure: false,
        issued: 1419191165408,
        url: '/socket.io/?EIO=3&transport=polling&t=1419191165380-17',
        query: [Object] },
     _events: 
      { authenticate: [Function],
        message: [Function],
        disconnect: [Function] },
     authToken: '76308cf591efe0fc229de6588fa1ec94',
     uid: 0 },
  Le5qQhQgFYEb0saoAAAC: 
   { nsp: 
      { name: '/',
        server: [Object],
        sockets: [Object],
        connected: [Object],
        fns: [],
        ids: 0,
        acks: {},
        adapter: [Object],
        _events: [Object] },
     server: 
      { nsps: [Object],
        _path: '/socket.io',
        _serveClient: true,
        _adapter: [Function: Adapter],
        _origins: '*:*',
        sockets: [Object],
        eio: [Object],
        httpServer: [Object],
        engine: [Object] },
     adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
     id: 'Le5qQhQgFYEb0saoAAAC',
     client: 
      { server: [Object],
        conn: [Object],
        encoder: {},
        decoder: [Object],
        id: 'Le5qQhQgFYEb0saoAAAC',
        request: [Object],
        onclose: [Function],
        ondata: [Function],
        onerror: [Function],
        ondecoded: [Function],
        sockets: [Object],
        nsps: [Object],
        connectBuffer: [] },
     conn: 
      { id: 'Le5qQhQgFYEb0saoAAAC',
        server: [Object],
        upgraded: false,
        readyState: 'open',
        writeBuffer: [],
        packetsFn: [],
        sentCallbackFn: [],
        request: [Object],
        remoteAddress: '127.0.0.1',
        checkIntervalTimer: null,
        upgradeTimeoutTimer: null,
        pingTimeoutTimer: [Object],
        transport: [Object],
        _events: [Object] },
     rooms: [ 'Le5qQhQgFYEb0saoAAAC' ],
     acks: {},
     connected: true,
     disconnected: false,
     handshake: 
      { headers: [Object],
        time: 'Sun Dec 21 2014 19:47:50 GMT+0000 (GMT)',
        address: '127.0.0.1',
        xdomain: true,
        secure: false,
        issued: 1419191270771,
        url: '/socket.io/?EIO=3&transport=polling&t=1419191270767-27',
        query: [Object] },
     _events: 
      { authenticate: [Function],
        message: [Function],
        disconnect: [Function] } } }
Still there Le5qQhQgFYEb0saoAAAC
Auth - 4
  socket.io:client writing packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +35ms
  socket.io-parser encoding packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +7ms
  socket.io-parser encoded {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} as 2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}] +0ms
  engine:socket sending packet "message" (2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]) +7ms
  engine:socket flushing buffer to transport +0ms
  engine:polling writing "     �42["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]" +0ms
Sent message to client Le5qQhQgFYEb0saoAAAC
Added - 4
Added channels for uid 4: nodejs_user_4
setupClientConnection { '4': [] }
  engine upgrading existing transport +3ms
  engine:socket might upgrade socket transport from "polling" to "websocket" +0ms
  engine intercepting request for path "/socket.io/" +4ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270809-31&sid=Le5qQhQgFYEb0saoAAAC" +1ms
  engine setting new request for existing client +0ms
  engine:polling setting request +0ms
  engine:socket executing batch send callback +0ms
  engine:ws received "2probe" +1ms
  engine:ws writing "3probe" +0ms
  engine:socket writing a noop packet to polling for fast upgrade +103ms
  engine:polling writing "�6" +0ms
  engine:ws received "5" +3ms
  engine:socket got upgrade packet - upgrading +0ms
  socket.io:client client close with reason transport close +145ms
  socket.io:socket closing socket - reason transport close +151ms
  socket.io:client ignoring remove for Le5qQhQgFYEb0saoAAAC +0ms
Out - 4
Cleaning up after socket id Le5qQhQgFYEb0saoAAAC uid 4
  socket.io:server serve client 304 +362ms
  engine intercepting request for path "/socket.io/" +701ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271357-0" +0ms
  engine handshaking client "9ftb7jOE4yqNvsdVAAAD" +0ms
  engine:socket sending packet "open" ({"sid":"9ftb7jOE4yqNvsdVAAAD","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}) +0ms
  engine:polling setting request +0ms
  engine:socket flushing buffer to transport +1ms
  engine:polling writing "	�0{"sid":"9ftb7jOE4yqNvsdVAAAD","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}" +0ms
  engine:socket executing batch send callback +1ms
  socket.io:server incoming connection with id 9ftb7jOE4yqNvsdVAAAD +491ms
  socket.io:client connecting to namespace / +673ms
  socket.io:namespace adding socket to nsp / +853ms
  socket.io:socket socket connected - writing packet +674ms
  socket.io:socket joining room 9ftb7jOE4yqNvsdVAAAD +0ms
  socket.io:client writing packet {"type":0,"nsp":"/"} +1ms
  socket.io-parser encoding packet {"type":0,"nsp":"/"} +819ms
  socket.io-parser encoded {"type":0,"nsp":"/"} as 0 +0ms
  engine:socket sending packet "message" (0) +1ms
  socket.io:socket joined room 9ftb7jOE4yqNvsdVAAAD +0ms
  engine intercepting request for path "/socket.io/" +108ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271658-1&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
  engine setting new request for existing client +1ms
  engine:polling setting request +0ms
  engine:socket flushing buffer to transport +0ms
  engine:polling writing "�40" +0ms
  engine:socket executing batch send callback +4ms
  engine intercepting request for path "/socket.io/" +48ms
  engine handling "OPTIONS" http request "/socket.io/?EIO=3&transport=polling&t=1419191271780-2&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
  engine setting new request for existing client +0ms
  engine intercepting request for path "/socket.io/" +3ms
  engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271781-3&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
  engine setting new request for existing client +0ms
  engine:polling setting request +0ms
  engine intercepting request for path "/socket.io/" +0ms
  engine handling "POST" http request "/socket.io/?EIO=3&transport=polling&t=1419191271780-2&sid=9ftb7jOE4yqNvsdVAAAD" +0ms
  engine setting new request for existing client +0ms
  engine:polling received "�42["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]" +1ms
  engine:socket packet +0ms
  socket.io-parser decoded 2["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] as {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +168ms
  socket.io:socket got packet {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +168ms
  socket.io:socket emitting event ["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] +0ms
Authenticating client with key "5449114a002aa956cc51ade10c1a8f1a"
Reusing existing authentication data for key: 5449114a002aa956cc51ade10c1a8f1a , client id: 9ftb7jOE4yqNvsdVAAAD
{ SJHuQncovQQBEDe8AAAA: 
   { nsp: 
      { name: '/',
        server: [Object],
        sockets: [Object],
        connected: [Object],
        fns: [],
        ids: 0,
        acks: {},
        adapter: [Object],
        _events: [Object] },
     server: 
      { nsps: [Object],
        _path: '/socket.io',
        _serveClient: true,
        _adapter: [Function: Adapter],
        _origins: '*:*',
        sockets: [Object],
        eio: [Object],
        httpServer: [Object],
        engine: [Object] },
     adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
     id: 'SJHuQncovQQBEDe8AAAA',
     client: 
      { server: [Object],
        conn: [Object],
        encoder: {},
        decoder: [Object],
        id: 'SJHuQncovQQBEDe8AAAA',
        request: [Object],
        onclose: [Function],
        ondata: [Function],
        onerror: [Function],
        ondecoded: [Function],
        sockets: [Object],
        nsps: [Object],
        connectBuffer: [] },
     conn: 
      { id: 'SJHuQncovQQBEDe8AAAA',
        server: [Object],
        upgraded: true,
        readyState: 'open',
        writeBuffer: [],
        packetsFn: [],
        sentCallbackFn: [],
        request: [Object],
        remoteAddress: '127.0.0.1',
        checkIntervalTimer: null,
        upgradeTimeoutTimer: [Object],
        pingTimeoutTimer: [Object],
        transport: [Object],
        _events: [Object] },
     rooms: [ 'SJHuQncovQQBEDe8AAAA' ],
     acks: {},
     connected: true,
     disconnected: false,
     handshake: 
      { headers: [Object],
        time: 'Sun Dec 21 2014 19:46:05 GMT+0000 (GMT)',
        address: '127.0.0.1',
        xdomain: true,
        secure: false,
        issued: 1419191165408,
        url: '/socket.io/?EIO=3&transport=polling&t=1419191165380-17',
        query: [Object] },
     _events: 
      { authenticate: [Function],
        message: [Function],
        disconnect: [Function] },
     authToken: '76308cf591efe0fc229de6588fa1ec94',
     uid: 0 },
  '9ftb7jOE4yqNvsdVAAAD': 
   { nsp: 
      { name: '/',
        server: [Object],
        sockets: [Object],
        connected: [Object],
        fns: [],
        ids: 0,
        acks: {},
        adapter: [Object],
        _events: [Object] },
     server: 
      { nsps: [Object],
        _path: '/socket.io',
        _serveClient: true,
        _adapter: [Function: Adapter],
        _origins: '*:*',
        sockets: [Object],
        eio: [Object],
        httpServer: [Object],
        engine: [Object] },
     adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
     id: '9ftb7jOE4yqNvsdVAAAD',
     client: 
      { server: [Object],
        conn: [Object],
        encoder: {},
        decoder: [Object],
        id: '9ftb7jOE4yqNvsdVAAAD',
        request: [Object],
        onclose: [Function],
        ondata: [Function],
        onerror: [Function],
        ondecoded: [Function],
        sockets: [Object],
        nsps: [Object],
        connectBuffer: [] },
     conn: 
      { id: '9ftb7jOE4yqNvsdVAAAD',
        server: [Object],
        upgraded: false,
        readyState: 'open',
        writeBuffer: [],
        packetsFn: [],
        sentCallbackFn: [],
        request: [Object],
        remoteAddress: '127.0.0.1',
        checkIntervalTimer: null,
        upgradeTimeoutTimer: null,
        pingTimeoutTimer: [Object],
        transport: [Object],
        _events: [Object] },
     rooms: [ '9ftb7jOE4yqNvsdVAAAD' ],
     acks: {},
     connected: true,
     disconnected: false,
     handshake: 
      { headers: [Object],
        time: 'Sun Dec 21 2014 19:47:51 GMT+0000 (GMT)',
        address: '127.0.0.1',
        xdomain: true,
        secure: false,
        issued: 1419191271624,
        url: '/socket.io/?EIO=3&transport=polling&t=1419191271357-0',
        query: [Object] },
     _events: 
      { authenticate: [Function],
        message: [Function],
        disconnect: [Function] } } }
Still there 9ftb7jOE4yqNvsdVAAAD
Auth - 4
  socket.io:client writing packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +176ms
  socket.io-parser encoding packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +8ms
  socket.io-parser encoded {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} as 2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}] +0ms
  engine:socket sending packet "message" (2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]) +8ms
  engine:socket flushing buffer to transport +0ms
  engine:polling writing "     �42["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]" +0ms
Sent message to client 9ftb7jOE4yqNvsdVAAAD
Added - 4
Added channels for uid 4: nodejs_user_4
setupClientConnection { '4': [] }