[rabbitmq-discuss] STOMP doesn't include the routing-key on MESSAGE frames

Tony Garnock-Jones tonygarnockjones+rabbitmq at gmail.com
Fri Feb 10 15:56:33 GMT 2012


Hi all,

Attempting to use the STOMP adapter the other day I discovered an
oversight in the new design: the AMQP routing key is no longer
propagated into outgoing MESSAGE frames. This stopped my application
from working.

Here's a patch (obviously crude, e.g. doesn't define a
?HEADER_ROUTING_KEY macro or anything) that causes the routing_key to
be sent along:

diff -r 3be0091c6401 src/rabbit_stomp_util.erl
--- a/src/rabbit_stomp_util.erl Wed Feb 08 15:53:59 2012 +0000
+++ b/src/rabbit_stomp_util.erl Fri Feb 10 10:53:21 2012 -0500
@@ -78,9 +78,11 @@

 message_headers(Destination, SessionId,
                 #'basic.deliver'{consumer_tag = ConsumerTag,
-                                 delivery_tag = DeliveryTag},
+                                 delivery_tag = DeliveryTag,
+                                 routing_key = RoutingKey},
                 Props = #'P_basic'{headers       = Headers}) ->
     Basic = [{?HEADER_DESTINATION, Destination},
+             {"amqp-routing-key", binary_to_list(RoutingKey)},
              {?HEADER_MESSAGE_ID,
               create_message_id(ConsumerTag, SessionId, DeliveryTag)}],


I'd be very happy to see this included into the master branch of the
STOMP adapter.

Regards,
  Tony
--
Tony Garnock-Jones
tonygarnockjones at gmail.com
http://homepages.kcbbs.gen.nz/tonyg/


More information about the rabbitmq-discuss mailing list