SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
574 Commits 28 Branches 0 Tags
ef8d3fde03bbc8e7add909b94dcc7bbb1a092e93
Commit Graph

9 Commits

Author SHA1 Message Date
bamboo
ef8d3fde03 [artifactory-release] Release version 1.1.0.RC1 2016-09-07 04:12:36 +00:00
Marius Bogoevici
d018cafee4 Subscribers to channel-wrapping Flux instances should broadcast 
Fixes #640
 2016-08-31 17:25:11 -04:00
bamboo
1b12f7d856 [artifactory-release] Next development version 2016-08-25 20:17:52 +00:00
bamboo
7b71e07c3a [artifactory-release] Release version 1.1.0.M1 2016-08-25 20:17:52 +00:00
Marius Bogoevici
512a5d9190 Use spring-cloud-build-tools for checkstyle validation 2016-08-25 15:27:28 -04:00
bamboo
5cd15dc300 [artifactory-release] Next development version 2016-08-25 19:10:15 +00:00
bamboo
749191ce20 [artifactory-release] Release version 1.1.0.M1 2016-08-25 19:10:15 +00:00
Marius Bogoevici
1b62be0217 Override scheduler implementations for Reactor 3.0.0 
Workaround for https://github.com/reactor/reactor-core/issues/159
 2016-08-25 12:13:09 -04:00
Marius Bogoevici
08d65a92bb Initial support for Reactive API 
Fixes #520
Fixes #458 (for non-reactive binders)

Adds spring-cloud-stream-reactive module.
Introduces support for declarative @StreamListener and @Input and @Output annotated parameters.
Add StreamListenerArgumentAdapter and StreamListenerResultAdapter for wrapping bindable inputs
and outputs when passing arguments to declarative @StreamListener.
Adds support for using reactive types (Flux/Observable) with traditional binders.
Introduce FluxSender and ObservableSender for handling multiple streaming outputs per method.
Ensure that errors are caught and logged.

Fixing constructor assertions and Javadoc

Addressing PR comments

- rework @Input/@Output parameter validation
- renamed StreamListenerArgumentAdapter to StreamListenerParameterAdapter
- ensure that parameter direction is accounted for in the current adapters
 2016-07-26 14:47:03 -04:00