diff --git a/spring-cloud-stream.html b/spring-cloud-stream.html index 923401361..c57407c16 100644 --- a/spring-cloud-stream.html +++ b/spring-cloud-stream.html @@ -417,7 +417,7 @@ body.book #toc,body.book #preamble,body.book h1.sect0,body.book .sect1>h2{page-b
-

This project allows a user to develop and run messaging microservices using Spring Integration and run them locally, or in the cloud, or even on Spring XD. Just add @EnableModule and run your app as a Spring Boot app (single application context). You just need to connect to the physical broker for the bus, which is automatic if the relevant bus implementation is available on the classpath. The sample uses Redis.

+

This project allows a user to develop and run messaging microservices using Spring Integration and run them locally, or in the cloud, or even on Spring XD. Just add @EnableBinding and run your app as a Spring Boot app (single application context). You just need to connect to the physical broker for the bindings, which is automatic if the relevant binder implementation is available on the classpath. The sample uses Redis.

Here’s a sample source module (output channel only):

@@ -435,7 +435,7 @@ public class ModuleApplication { } @Configuration -@EnableModule(Source.class) +@EnableBinding(Source.class) public class TimerSource { @Value("${format}") @@ -451,7 +451,7 @@ public class TimerSource {
-

@EnableModule is parameterized by an interface (in this case Source) which declares input and output channels. Source, Sink and Processor are provided off the shelf, but you can define others. Here’s the definition of Source

+

@EnableBinding is parameterized by an interface (in this case Source) which declares input and output channels. Source, Sink and Processor are provided off the shelf, but you can define others. Here’s the definition of Source:

@@ -490,7 +490,7 @@ public class ModuleApplicationTests {
Note
-In this case there is only one Source in the application context so there is no need to qualify it when it is autowired. If there is ambiguity, e.g. if you are composing one module from some others, you can use @ModuleChannels qualifier to inject a specific channel set. The @ModuleChannels qualifier takes a parameter which is the class that carries the @EnableModule annotation (in this case the TimerSource). +In this case there is only one Source in the application context so there is no need to qualify it when it is autowired. If there is ambiguity, e.g. if you are composing one module from some others, you can use @Bindings qualifier to inject a specific channel set. The @Bindings qualifier takes a parameter which is the class that carries the @EnableBinding annotation (in this case the TimerSource). @@ -582,7 +582,7 @@ The main set of samples are "vanilla" in the sense that they are not deployable