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

Correct example in the documentation

Browse Source 
Fixes #586
This commit is contained in:
Marius Bogoevici
2016-08-18 13:19:15 -04:00
committed by markfisher
parent d43f1d42fc
commit bac8877a52
1 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-cloud-stream-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc
View File

@@ -15,17 +15,12 @@ The following is a simple sink application which receives external messages.
[source,java]
----
@SpringBootApplication
public class StreamApplication {
@EnableBinding(Sink.class)
public class VoteRecordingSinkApplication {
public static void main(String[] args) {
SpringApplication.run(StreamApplication.class, args);
SpringApplication.run(VoteRecordingSinkApplication.class, args);
}
}
@EnableBinding(Sink.class)
public class TimerSource {
...
@StreamListener(Sink.INPUT)
public void processVote(Vote vote) {
@@ -38,7 +33,7 @@ The `@EnableBinding` annotation takes one or more interfaces as parameters (in t
An interface declares input and/or output channels.
Spring Cloud Stream provides the interfaces `Source`, `Sink`, and `Processor`; you can also define your own interfaces.
The following is the definition of the `Source` interface:
The following is the definition of the `Sink` interface:
[source,java]
----
@@ -59,7 +54,7 @@ You can use this in the application by autowiring it, as in the following exampl
[source,java]
----
@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = StreamApplication.class)
@SpringApplicationConfiguration(classes = VoteRecordingSinkApplication.class)
@WebAppConfiguration
@DirtiesContext
public class StreamApplicationTests {