Modifier and Type | Method and Description |
---|---|
CamelReactiveStreamsService |
ReactiveStreamsComponent.getReactiveStreamsService()
Lazy creation of the CamelReactiveStreamsService
|
static CamelReactiveStreamsService |
ReactiveStreamsHelper.resolveReactiveStreamsService(org.apache.camel.CamelContext context,
String serviceType,
ReactiveStreamsEngineConfiguration configuration)
Helper to lookup/create an instance of
CamelReactiveStreamsService |
Constructor and Description |
---|
ReactiveStreamsConsumer(ReactiveStreamsEndpoint endpoint,
org.apache.camel.Processor processor,
CamelReactiveStreamsService service) |
ReactiveStreamsProducer(ReactiveStreamsEndpoint endpoint,
String name,
CamelReactiveStreamsService service) |
Modifier and Type | Method and Description |
---|---|
static CamelReactiveStreamsService |
CamelReactiveStreams.get(org.apache.camel.CamelContext context) |
CamelReactiveStreamsService |
CamelReactiveStreamsServiceFactory.newInstance(org.apache.camel.CamelContext context,
ReactiveStreamsEngineConfiguration configuration)
Creates a new instance of the
ReactiveStreamsEngineConfiguration |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCamelReactiveStreamsService
The default implementation of the reactive streams service.
|
Modifier and Type | Method and Description |
---|---|
CamelReactiveStreamsService |
DefaultCamelReactiveStreamsServiceFactory.newInstance(org.apache.camel.CamelContext context,
ReactiveStreamsEngineConfiguration configuration) |
Apache Camel