Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-2034 clearing the replyTo address after it has been used (i.e. it is not copied along with the reply Message itself)

Browse Source
This commit is contained in:
Mark Fisher
2011-08-04 23:14:11 -04:00
parent 89bef1e6f6
commit ea19a7d5a2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java
View File

@@ -84,7 +84,9 @@ public class AmqpInboundGateway extends MessagingGatewaySupport {
amqpTemplate.convertAndSend(replyTo.getExchangeName(), replyTo.getRoutingKey(), reply.getPayload(),
new MessagePostProcessor() {
public Message postProcessMessage(Message message) throws AmqpException {
headerMapper.fromHeaders(reply.getHeaders(), message.getMessageProperties());
headerMapper.fromHeaders(reply.getHeaders(), message.getMessageProperties());
// clear the replyTo from the original message since we are using it now
message.getMessageProperties().setReplyTo(null);
return message;
}
});