2b1ccc4c7c
- Add a way to enable `RxJava` module
- Add `EnableRxJavaModule` annotation that inherits `EnableModule` for `Processor` type.
- It also registers the custom `MessageHandler` that sets up RxJava `Observable/Subscriber` to process the incoming message reactively.
- Introduce `RxJavaProcessor` that is expected to be implemented by the module author with the input/output being `Observable`. This processor is autowired into the message handler registered above.
- Add moving average sample
Add project `spring-cloud-stream-rxjava`
- This project extends `spring-cloud-stream` so that any RxJava processing module would have this as a dependency
9 lines
114 B
YAML
9 lines
114 B
YAML
server:
|
|
port: 8082
|
|
spring:
|
|
cloud:
|
|
stream:
|
|
bindings:
|
|
output: xformed
|
|
input: testtock
|