mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add Stream processing example

Browse Source
This commit is contained in:
Ivan Paolillo
2016-09-01 12:20:44 +02:00
parent d9da586447
commit 54d3d40e72
16 changed files with 347 additions and 347 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-cloud-data-flow/time-source/src/main/java/org/baeldung/spring/cloud/TimeSourceApplication.java
View File

@@ -16,14 +16,14 @@ import org.springframework.integration.support.MessageBuilder;
@SpringBootApplication
public class TimeSourceApplication {
@Bean
@InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "10000", maxMessagesPerPoll = "1"))
public MessageSource<Long> timeMessageSource() {
@Bean
@InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "10000", maxMessagesPerPoll = "1"))
public MessageSource<Long> timeMessageSource() {
return () -> MessageBuilder.withPayload(new Date().getTime()).build();
}
return () -> MessageBuilder.withPayload(new Date().getTime()).build();
}
public static void main(String[] args) {
SpringApplication.run(TimeSourceApplication.class, args);
}
public static void main(String[] args) {
SpringApplication.run(TimeSourceApplication.class, args);
}
}

6
spring-cloud-data-flow/time-source/src/test/java/org/baeldung/spring/cloud/TimeSourceApplicationTests.java
View File

@@ -9,8 +9,8 @@ import org.springframework.test.context.junit4.SpringRunner;
@SpringBootTest
public class TimeSourceApplicationTests {
@Test
public void contextLoads() {
}
@Test
public void contextLoads() {
}
}