Apply aRPPs for replies with a listener container

- `afterReceivePostProcessors` were not applied when using
  a reply container.

Author: garyrussell

.gitignore

@@ -19,3 +19,4 @@ erl_crash.dump
 nohup.out
 src/ant/.ant-targets-upload-dist.xml
 target
+.sts4-cache/

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java

@@ -1936,6 +1936,11 @@ private Message doSendAndReceiveAsListener(final String exchange, final String r
 		try {
 			reply = exchangeMessages(exchange, routingKey, message, correlationData, channel, pendingReply,
 					messageTag);
+			if (reply != null && this.afterReceivePostProcessors != null) {
+				for (MessagePostProcessor processor : this.afterReceivePostProcessors) {
+					reply = processor.postProcessMessage(reply);
+				}
+			}
 		}
 		finally {
 			this.replyHolder.remove(messageTag);

spring-rabbit/src/test/java/org/springframework/amqp/rabbit/annotation/EnableRabbitIntegrationTests.java

@@ -409,6 +409,25 @@ public void endpointWithHeader() {
 		assertEquals(reply.getMessageProperties().getHeaders().get("replyMPPApplied"), Boolean.TRUE);
 	}
 
+	@Test
+	public void endpointWithHeaderReplyMPP() {
+		MessageProperties properties = new MessageProperties();
+		properties.setHeader("prefix", "prefix-");
+		Message request = MessageTestUtils.createTextMessage("foo", properties);
+		AtomicReference<Message> replyRef = new AtomicReference<>();
+		rabbitTemplate.setAfterReceivePostProcessors(msg -> {
+			replyRef.set(msg);
+			return msg;
+		});
+		rabbitTemplate.convertSendAndReceive("", "test.header", "", msg -> {
+			return request;
+		});
+		Message reply = replyRef.get();
+		assertNotNull(reply);
+		assertEquals("prefix-FOO", MessageTestUtils.extractText(reply));
+		assertEquals(reply.getMessageProperties().getHeaders().get("replyMPPApplied"), Boolean.TRUE);
+	}
+
 	@Test
 	public void endpointWithMessage() {
 		MessageProperties properties = new MessageProperties();