diff --git a/lib/connection.js b/lib/connection.js index 622b3251..3db19316 100644 --- a/lib/connection.js +++ b/lib/connection.js @@ -318,7 +318,7 @@ p.parse2 = function(msg) { p.parseA = function(msg) { msg.processId = this.parseInt32(); msg.channel = this.parseCString(); - msg.message = this.parseCString(); + msg.payload = this.parseCString(); return msg; }; diff --git a/test/test-buffers.js b/test/test-buffers.js index ca4c27b5..184fa55b 100644 --- a/test/test-buffers.js +++ b/test/test-buffers.js @@ -98,11 +98,11 @@ buffers.bindComplete = function() { return new BufferList().join(true, '2'); }; -buffers.notificationResponse = function(id, channel, message) { +buffers.notificationResponse = function(id, channel, payload) { return new BufferList() .addInt32(id) .addCString(channel) - .addCString(message) + .addCString(payload) .join(true, 'A') }; diff --git a/test/unit/connection/inbound-parser-tests.js b/test/unit/connection/inbound-parser-tests.js index 46013be7..f8d482c4 100644 --- a/test/unit/connection/inbound-parser-tests.js +++ b/test/unit/connection/inbound-parser-tests.js @@ -158,7 +158,7 @@ var expectedNotificationResponseMessage = { id: 'A', processId: 4, channel: 'hi', - message: 'boom' + payload: 'boom' }; test('Connection', function() {