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

Fix RedisQueueMessageDrEndpointTests for Java 14

Browse Source
This commit is contained in:
Artem Bilan
2020-06-24 12:43:12 -04:00
parent 6a3bea5a64
commit 5d7f0d2d1c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisQueueMessageDrivenEndpointTests.java
View File

@@ -195,7 +195,7 @@ public class RedisQueueMessageDrivenEndpointTests extends RedisAvailableTests {
assertThat(((Exception) receive.getPayload()).getMessage()).contains("Deserialization of Message failed."); assertThat(((Exception) receive.getPayload()).getMessage()).contains("Deserialization of Message failed.");
assertThat(((Exception) receive.getPayload()).getCause()).isInstanceOf(ClassCastException.class); assertThat(((Exception) receive.getPayload()).getCause()).isInstanceOf(ClassCastException.class);
assertThat(((Exception) receive.getPayload()).getCause().getMessage()) assertThat(((Exception) receive.getPayload()).getCause().getMessage())
.contains("java.lang.String cannot be cast to org.springframework.messaging.Message"); .contains("java.lang.String cannot be cast");
CountDownLatch stopLatch = new CountDownLatch(1); CountDownLatch stopLatch = new CountDownLatch(1);
endpoint.stop(stopLatch::countDown); endpoint.stop(stopLatch::countDown);