From 93959dd9f01689010c823ec6326768b440467705 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 29 Aug 2018 06:45:24 -0500 Subject: [PATCH] Polished testSourceFromSupplier to demonstrate the default poller configuration --- .../stream/function/GreenfieldFunctionEnableBindingTests.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java index 458e9a637..5eac13e0e 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/GreenfieldFunctionEnableBindingTests.java @@ -61,6 +61,10 @@ public class GreenfieldFunctionEnableBindingTests { Message 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)); } }