@UriEndpoint(firstVersion="2.19.0", scheme="reactive-streams", title="Reactive Streams", syntax="reactive-streams:stream", consumerClass=ReactiveStreamsConsumer.class, label="reactive,streams") @ManagedResource(description="Managed ReactiveStreamsEndpoint") public class ReactiveStreamsEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
ReactiveStreamsEndpoint(String endpointUri,
ReactiveStreamsComponent component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
ReactiveStreamsBackpressureStrategy |
getBackpressureStrategy() |
int |
getConcurrentConsumers() |
double |
getExchangesRefillLowWatermark() |
Integer |
getMaxInflightExchanges() |
String |
getStream() |
boolean |
isForwardOnComplete() |
boolean |
isForwardOnError() |
boolean |
isSingleton() |
void |
setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
The backpressure strategy to use when pushing events to a slow subscriber.
|
void |
setConcurrentConsumers(int concurrentConsumers)
Number of threads used to process exchanges in the Camel route.
|
void |
setExchangesRefillLowWatermark(double exchangesRefillLowWatermark)
Set the low watermark of requested exchanges to the active subscription as percentage of the maxInflightExchanges.
|
void |
setForwardOnComplete(boolean forwardOnComplete)
Determines if onComplete events should be pushed to the Camel route.
|
void |
setForwardOnError(boolean forwardOnError)
Determines if onError events should be pushed to the Camel route.
|
void |
setMaxInflightExchanges(Integer maxInflightExchanges)
Maximum number of exchanges concurrently being processed by Camel.
|
void |
setStream(String stream)
Name of the stream channel used by the endpoint to exchange messages.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ReactiveStreamsEndpoint(String endpointUri, ReactiveStreamsComponent component)
public boolean isSingleton()
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
@ManagedAttribute(description="Name of the stream channel used by the endpoint to exchange messages") public String getStream()
public void setStream(String stream)
@ManagedAttribute(description="Maximum number of exchanges concurrently being processed by Camel") public Integer getMaxInflightExchanges()
public void setMaxInflightExchanges(Integer maxInflightExchanges)
public int getConcurrentConsumers()
@ManagedAttribute(description="Number of threads used to process exchanges in the Camel route") public void setConcurrentConsumers(int concurrentConsumers)
public ReactiveStreamsBackpressureStrategy getBackpressureStrategy()
public void setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
@ManagedAttribute(description="Determines if onComplete events should be pushed to the Camel route") public boolean isForwardOnComplete()
public void setForwardOnComplete(boolean forwardOnComplete)
@ManagedAttribute(description="Determines if onError events should be pushed to the Camel route") public boolean isForwardOnError()
public void setForwardOnError(boolean forwardOnError)
@ManagedAttribute(description="The percentage of maxInflightExchanges below which new items can be requested to the source subscription") public double getExchangesRefillLowWatermark()
public void setExchangesRefillLowWatermark(double exchangesRefillLowWatermark)
Apache Camel