Skip to content

Commit d828987

Browse files
committed
Give the reply frame for specific events
1 parent dc5c83e commit d828987

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

lib/stomp.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,13 @@ Stomp.prototype.connect = function(headers) {
4141
self.emit('connected');
4242
break;
4343
case "MESSAGE":
44-
self.emit('message');
44+
self.emit('message', reply_frame);
4545
break;
4646
case "RECEIPT":
47-
self.emit('receipt');
47+
self.emit('receipt', reply_frame.headers['receipt']);
4848
break;
4949
case "ERROR":
50-
self.emit('error');
50+
self.emit('error', reply_frame);
5151
break;
5252
}
5353
});

stomp-client.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,3 +21,7 @@ client.on('connected', function() {
2121
});
2222
}
2323
});
24+
25+
client.on('message', function(message) {
26+
console.log(message.body);
27+
});

0 commit comments

Comments
 (0)