File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -294,7 +294,8 @@ Stomp.prototype.is_a_message = function(this_frame) {
294
294
// Takes a `Frame` object
295
295
//
296
296
Stomp . prototype . should_run_message_callback = function ( this_frame ) {
297
- var subscription = this . _subscribed_to [ this_frame . headers . destination ] ;
297
+ // The matching subscribed queue will be found in the subscription headers in the case of a reply-to temp queue with rabbitmq
298
+ var subscription = this . _subscribed_to [ this_frame . headers . destination ] || this . _subscribed_to [ this_frame . headers . subscription ] ;
298
299
if ( this_frame . headers . destination !== null && subscription !== null ) {
299
300
if ( subscription . enabled && subscription . callback !== null && typeof ( subscription . callback ) == 'function' ) {
300
301
subscription . callback ( this_frame . body , this_frame . headers ) ;
You can’t perform that action at this time.
0 commit comments