SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Rabbit tests

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-09-12 15:27:52 +02:00
parent 1f9418754a
commit fbdf2dc40b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java
View File

@@ -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);