Add Stream processing example

2016-09-01 10:57:47 +02:00
parent cc9370e8ff
commit d9da586447
41 changed files with 2459 additions and 0 deletions
@@ -0,0 +1,29 @@
+package org.baeldung.spring.cloud;
+
+import java.util.Date;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.messaging.Source;
+import org.springframework.context.annotation.Bean;
+import org.springframework.integration.annotation.InboundChannelAdapter;
+import org.springframework.integration.annotation.Poller;
+import org.springframework.integration.core.MessageSource;
+import org.springframework.integration.support.MessageBuilder;
+
+@EnableBinding(Source.class)
+@SpringBootApplication
+public class TimeSourceApplication {
+
+	@Bean
+	@InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "10000", maxMessagesPerPoll = "1"))
+	public MessageSource<Long> timeMessageSource() {
+
+		return () -> MessageBuilder.withPayload(new Date().getTime()).build();
+	}
+
+	public static void main(String[] args) {
+		SpringApplication.run(TimeSourceApplication.class, args);
+	}
+}