Author: chirino Date: Wed Aug 1 16:02:38 2012 New Revision: 1368088 URL: http://svn.apache.org/viewvc?rev=1368088&view=rev Log: When converting another protocol into a stomp message use the original sending destination. Modified: activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala Modified: activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala?rev=1368088&r1=1368087&r2=1368088&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala (original) +++ activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala Wed Aug 1 16:02:38 2012 @@ -433,7 +433,7 @@ class StompProtocolHandler extends Proto var headers = (MESSAGE_ID -> ascii(session_id.get+message_id_counter)) :: Nil headers ::= (CONTENT_TYPE -> ascii(content_type)) headers ::= (CONTENT_LENGTH -> ascii(body.length().toString)) - headers ::= (DESTINATION -> encode_header(destination_parser.encode_destination(delivery.sender))) + headers ::= (DESTINATION -> encode_header(destination_parser.encode_destination(delivery.sender.head))) StompFrame(MESSAGE, headers, BufferContent(body)) }