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

Polished testSourceFromSupplier

Browse Source 
to demonstrate the default poller configuration
This commit is contained in:
Oleg Zhurakousky
2018-08-29 06:45:24 -05:00
parent 20a443081b
commit 93959dd9f0
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java
View File

@@ -61,6 +61,10 @@ public class GreenfieldFunctionEnableBindingTests {
Message<byte[]> sourceMessage = target.receive(10000);
Date date = (Date) new CompositeMessageConverterFactory().getMessageConverterForAllRegistered().fromMessage(sourceMessage, Date.class);
assertThat(date).isEqualTo(new Date(12345L));
sourceMessage = target.receive(10000);
date = (Date) new CompositeMessageConverterFactory().getMessageConverterForAllRegistered().fromMessage(sourceMessage, Date.class);
assertThat(date).isEqualTo(new Date(12345L));
}
}