Jakub Scholz created QPID-7391:
----------------------------------
Summary: qpid-receive doesn't always honor the routing key from
the reply-to address when replying
Key: QPID-7391
URL: https://issues.apache.org/jira/browse/QPID-7391
Project: Qpid
Issue Type: Bug
Reporter: Jakub Scholz
When qpid-receive receives a message which contains reply-to address it tries
reply and send the received message back as a response. The reply-to address is
used to create the sender and the original message is sent back over this
sender. However, in case the original message already contains a different
routing key / subject, it will stay with the message and override the routing
key form the sender. As a result, the response message is sent with the routing
key used for the original message not with the routing key from the reply-to
address. See the following log as an example:
{code}
2016-08-11 12:39:04 [Network] trace RECV [[[::1]:36138-localhost:5672]]:
Frame[Bbe; channel=1; {MessageTransferBody:
destination=request_be.ABCFR_ABCFRALMMACC1; accept-mode=0; acquire-mode=0; }]
2016-08-11 12:39:04 [Network] trace RECV [[[::1]:36138-localhost:5672]]:
Frame[be; channel=1; header (192 bytes); properties={{MessageProperties:
content-length=1024; reply-to={ReplyTo: exchange=response;
routing-key=response.ABCFR_ABCFRALMMACC1.response_queue_1; };
content-type=text/plain; user-id=;
application-headers={qpid.subject:V2:11:str16(someSubject),sn:F4:uint32(1),ts:F8:int64(1470933541265281533)};
}{DeliveryProperties: delivery-mode=2; exchange=request.ABCFR_ABCFRALMMACC1;
routing-key=someSubject; }}]
2016-08-11 12:39:04 [Network] trace RECV [[[::1]:36138-localhost:5672]]:
Frame[Ebe; channel=1; content (1024 bytes) XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX...]
2016-08-11 12:39:04 [Network] trace SENT [[[::1]:36138-localhost:5672]]:
Frame[BEbe; channel=1; {SessionCompletedBody: commands={ }; timely-reply=1; }]
2016-08-11 12:39:04 [Client] debug Delivered {MessageTransferBody:
destination=request_be.ABCFR_ABCFRALMMACC1; accept-mode=0; acquire-mode=0; }
header (192 bytes); properties={{MessageProperties: content-length=1024;
reply-to={ReplyTo: exchange=response;
routing-key=response.ABCFR_ABCFRALMMACC1.response_queue_1; };
content-type=text/plain; user-id=;
application-headers={qpid.subject:V2:11:str16(someSubject),sn:F4:uint32(1),ts:F8:int64(1470933541265281533)};
}{DeliveryProperties: delivery-mode=2; exchange=request.ABCFR_ABCFRALMMACC1;
routing-key=someSubject; }}
2016-08-11 12:39:04 [Client] debug treating target address as topic:
response/response.ABCFR_ABCFRALMMACC1.response_queue_1;{node:{type:topic}}
2016-08-11 12:39:04 [Network] trace SENT [[[::1]:36138-localhost:5672]]:
Frame[BEbe; channel=1; {SessionCompletedBody: commands={ [0,0] }; }]
2016-08-11 12:39:04 [Network] trace SENT [[[::1]:36138-localhost:5672]]:
Frame[BEbe; channel=1; {ExchangeDeclareBody: exchange=response; type=;
alternate-exchange=; passive=1; arguments={}; }]
2016-08-11 12:39:04 [Network] trace RECV [[[::1]:36138-localhost:5672]]:
Frame[BEbe; channel=1; {SessionKnownCompletedBody: commands={ }; }]
2016-08-11 12:39:04 [Network] trace RECV [[[::1]:36138-localhost:5672]]:
Frame[BEbe; channel=1; {SessionCompletedBody: commands={ [0,7] }; }]
2016-08-11 12:39:04 [Client] debug Sending to exchange response
{MessageProperties: content-length=1024; content-type=text/plain; user-id=;
application-headers={qpid.subject:V2:11:str16(someSubject),sn:F4:uint32(1),ts:F8:int64(1470933541265281533),x-amqp-0-10.routing-key:V2:11:vbin16(someSubject)};
} {DeliveryProperties: delivery-mode=2; routing-key=someSubject; }
303 2851.59 2851.59 2851.59
2016-08-11 12:39:04 [Network] trace SENT [[[::1]:36138-localhost:5672]]:
Frame[Bbe; channel=1; {MessageTransferBody: destination=response;
accept-mode=1; acquire-mode=0; }]
2016-08-11 12:39:04 [Network] trace SENT [[[::1]:36138-localhost:5672]]:
Frame[be; channel=1; header (170 bytes); properties={{MessageProperties:
content-length=1024; content-type=text/plain; user-id=;
application-headers={qpid.subject:V2:11:str16(someSubject),sn:F4:uint32(1),ts:F8:int64(1470933541265281533),x-amqp-0-10.routing-key:V2:11:vbin16(someSubject)};
}{DeliveryProperties: delivery-mode=2; routing-key=someSubject; }}]
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
