From 76eb34256e422addb66adcea1dcb82569c6bc986 Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Fri, 14 Aug 2015 15:23:06 -0400 Subject: [PATCH] Set autoStartup to false on the TimeSource Prevents the endpoint from starting before it's bound, thus throwing Dispatcher errors --- .../source/src/main/java/source/TimeSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-samples/source/src/main/java/source/TimeSource.java b/spring-cloud-stream-samples/source/src/main/java/source/TimeSource.java index 11c81b407..c7148a76d 100644 --- a/spring-cloud-stream-samples/source/src/main/java/source/TimeSource.java +++ b/spring-cloud-stream-samples/source/src/main/java/source/TimeSource.java @@ -42,7 +42,7 @@ public class TimeSource { private TimeSourceOptionsMetadata options; @Bean - @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "${fixedDelay}", maxMessagesPerPoll = "1")) + @InboundChannelAdapter(value = Source.OUTPUT, autoStartup = "false", poller = @Poller(fixedDelay = "${fixedDelay}", maxMessagesPerPoll = "1")) public MessageSource timerMessageSource() { return () -> new GenericMessage<>(new SimpleDateFormat(this.options.getFormat()).format(new Date())); }