public class ReactiveStreamsComponent
extends org.apache.camel.impl.DefaultComponent
Constructor and Description |
---|
ReactiveStreamsComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected void |
doStart() |
protected void |
doStop() |
ReactiveStreamsBackpressureStrategy |
getBackpressureStrategy() |
ReactiveStreamsEngineConfiguration |
getInternalEngineConfiguration() |
CamelReactiveStreamsService |
getReactiveStreamsService()
Lazy creation of the CamelReactiveStreamsService
|
String |
getServiceType() |
void |
setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
The backpressure strategy to use when pushing events to a slow subscriber.
|
void |
setInternalEngineConfiguration(ReactiveStreamsEngineConfiguration internalEngineConfiguration)
Configures the internal engine for Reactive Streams.
|
void |
setServiceType(String serviceType)
Set the type of the underlying reactive streams implementation to use.
|
static ReactiveStreamsComponent |
withServiceType(String serviceType) |
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public ReactiveStreamsEngineConfiguration getInternalEngineConfiguration()
public void setInternalEngineConfiguration(ReactiveStreamsEngineConfiguration internalEngineConfiguration)
public ReactiveStreamsBackpressureStrategy getBackpressureStrategy()
public void setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
public String getServiceType()
public void setServiceType(String serviceType)
serviceType
- the reactive service implementation name typepublic CamelReactiveStreamsService getReactiveStreamsService()
public static final ReactiveStreamsComponent withServiceType(String serviceType)
Apache Camel