From b4c7690cf18865319c230ec8de691c50a9af7762 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 22 Dec 2017 12:35:09 -0500 Subject: [PATCH] Fix SqsMessageDrivenChannelAdapterTests https://build.spring.io/browse/INTEXT-AWS-JOB1-132 --- .../aws/inbound/SqsMessageDrivenChannelAdapterTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/org/springframework/integration/aws/inbound/SqsMessageDrivenChannelAdapterTests.java b/src/test/java/org/springframework/integration/aws/inbound/SqsMessageDrivenChannelAdapterTests.java index 8eff368..0272377 100644 --- a/src/test/java/org/springframework/integration/aws/inbound/SqsMessageDrivenChannelAdapterTests.java +++ b/src/test/java/org/springframework/integration/aws/inbound/SqsMessageDrivenChannelAdapterTests.java @@ -79,11 +79,11 @@ public class SqsMessageDrivenChannelAdapterTests { org.springframework.messaging.Message receive = this.inputChannel.receive(1000); assertThat(receive).isNotNull(); assertThat((String) receive.getPayload()).isIn("messageContent", "messageContent2"); - assertThat(receive.getHeaders().get(AwsHeaders.QUEUE)).isEqualTo("testQueue"); + assertThat(receive.getHeaders().get(AwsHeaders.RECEIVED_QUEUE)).isEqualTo("testQueue"); receive = this.inputChannel.receive(1000); assertThat(receive).isNotNull(); assertThat((String) receive.getPayload()).isIn("messageContent", "messageContent2"); - assertThat(receive.getHeaders().get(AwsHeaders.QUEUE)).isEqualTo("testQueue"); + assertThat(receive.getHeaders().get(AwsHeaders.RECEIVED_QUEUE)).isEqualTo("testQueue"); try { this.controlBusInput.send(new GenericMessage<>("@sqsMessageDrivenChannelAdapter.stop('testQueue')"));