Package | Description |
---|---|
org.apache.camel.component.reactive.streams | |
org.apache.camel.component.reactive.streams.api | |
org.apache.camel.component.reactive.streams.engine |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamsConsumer |
ReactiveStreamsCamelSubscriber.getConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
ReactiveStreamsCamelSubscriber.attachConsumer(ReactiveStreamsConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamsCamelSubscriber |
CamelReactiveStreamsService.attachCamelConsumer(String name,
ReactiveStreamsConsumer consumer)
Used by Camel to associate the subscriber of the stream with the given name to a specific Camel consumer.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamsCamelSubscriber |
DefaultCamelReactiveStreamsService.attachCamelConsumer(String name,
ReactiveStreamsConsumer consumer) |
Apache Camel