diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java index 8284a8609..ff65efdc6 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java @@ -383,7 +383,7 @@ public class RabbitBinderTests extends moduleOutputChannel.send(message); Confirm confirm = correlation.getFuture().get(10, TimeUnit.SECONDS); assertThat(confirm.isAck()).isTrue(); - assertThat(correlation.getReturnedMessage()).isNotNull(); + assertThat(correlation.getReturned()).isNotNull(); producerBinding.unbind(); verifyAutoDeclareContextClear(binder);