implicit subscription support about stomp-websocket HOT 9 CLOSED

but how do you subscribe to temp queues to receive messages sent on it?

from stomp-websocket.

Implicit subscriptions are created when temporary destinations are used.

from stomp-websocket.

If I understand you correctly, if a client SEND a message with a reply-to header, he is automatically subscribed to this temporary queue.
If this is done automatically on the broker side, I don't see why it'd not work with stomp.js.

from stomp-websocket.

An implicit subscription is set up on the broker if the "reply-to" value starts with "/temp-queue/".

Thanks for suggesting that this already work with stomp.js. Can you confirm which callback will be used to deliver messages that arrive for implicit subscriptions?

from stomp-websocket.

actually, you're right, no callback will be used to deliver the messages.

The issue is in https://github.com/jmesnil/stomp-websocket/blob/master/src/stomp.coffee#L211 where we lookup the callback registered in the subscribe methods. If none is found, the received message is discarded. That's wrong.

One way to get the temp queue working would be to allow the client to define a onreceive(message) callback that will be used if no callback is found in @subscriptions.
Then your code would look like:

var client = Stomp.client(...);
client.onreceive = function(message) {
    // receive message from temp queues
};
client.send(destination, {'reply-to': '/temp-queue/foo'}, "hello");

Would you be up to contribute a patch? :)

from stomp-websocket.

If there is anything that needs to be done on the broker side or testing then I can certainly help with that.

from stomp-websocket.

I've create branch to fix this at https://github.com/jmesnil/stomp-websocket/tree/implicit_subscription_support

Could you try using the corresponding stomp.js and tell me if that allows you to receive message from temp queues?

thanks

from stomp-websocket.

Thanks alot, that appears to work for me.

from stomp-websocket.

I've pushed the commit to stomp.js master.

I also proposed a PR for rabbitmq-web-stomp-examples to demonstrates how to use temporary queues (tested with RabbitMQ 3.1.4): rabbitmq/rabbitmq-web-stomp-examples#3

from stomp-websocket.