- SCHEME - Static variable in class org.apache.camel.component.reactive.streams.ReactiveStreamsConstants
-
- sendCamelExchange(String, Exchange) - Method in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService
-
Used by Camel to send the exchange to all active subscriptions on the given stream.
- sendCamelExchange(String, Exchange) - Method in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService
-
- SERVICE_PATH - Static variable in class org.apache.camel.component.reactive.streams.ReactiveStreamsConstants
-
- setBackpressureStrategy(ReactiveStreamsBackpressureStrategy) - Method in class org.apache.camel.component.reactive.streams.engine.CamelSubscription
-
- setBackpressureStrategy(ReactiveStreamsBackpressureStrategy) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsComponent
-
The backpressure strategy to use when pushing events to a slow subscriber.
- setBackpressureStrategy(ReactiveStreamsBackpressureStrategy) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
The backpressure strategy to use when pushing events to a slow subscriber.
- setCamelContext(CamelContext) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsConverter
-
- setConcurrentConsumers(int) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Number of threads used to process exchanges in the Camel route.
- setData(T) - Method in class org.apache.camel.component.reactive.streams.engine.DelayedMonoPublisher
-
- setException(Throwable) - Method in class org.apache.camel.component.reactive.streams.engine.DelayedMonoPublisher
-
- setExchangesRefillLowWatermark(double) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Set the low watermark of requested exchanges to the active subscription as percentage of the maxInflightExchanges.
- setForwardOnComplete(boolean) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Determines if onComplete events should be pushed to the Camel route.
- setForwardOnError(boolean) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Determines if onError events should be pushed to the Camel route.
- setInternalEngineConfiguration(ReactiveStreamsEngineConfiguration) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsComponent
-
Configures the internal engine for Reactive Streams.
- setMaxInflightExchanges(Integer) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Maximum number of exchanges concurrently being processed by Camel.
- setServiceType(String) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsComponent
-
Set the type of the underlying reactive streams implementation to use.
- setStream(String) - Method in class org.apache.camel.component.reactive.streams.ReactiveStreamsEndpoint
-
Name of the stream channel used by the endpoint to exchange messages.
- setThreadPoolMaxSize(int) - Method in class org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration
-
The maximum number of threads used by the reactive streams internal engine.
- setThreadPoolMinSize(int) - Method in class org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration
-
The minimum number of threads used by the reactive streams internal engine.
- setThreadPoolName(String) - Method in class org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration
-
The name of the thread pool used by the reactive streams internal engine.
- signalCompletion() - Method in class org.apache.camel.component.reactive.streams.engine.CamelSubscription
-
- streamSubscriber(String) - Method in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService
-
Returns the subscriber associated to the given stream name.
- streamSubscriber(String, Class<T>) - Method in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService
-
Returns the subscriber associated to the given stream name.
- streamSubscriber(String) - Method in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService
-
- streamSubscriber(String, Class<T>) - Method in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService
-
- subscribe(Subscriber<? super Exchange>) - Method in class org.apache.camel.component.reactive.streams.engine.CamelPublisher
-
- subscribe(Subscriber<? super T>) - Method in class org.apache.camel.component.reactive.streams.engine.DelayedMonoPublisher
-
- subscribe(Subscriber<? super Exchange>) - Method in class org.apache.camel.component.reactive.streams.engine.UnwrappingPublisher
-
- subscribe(Subscriber<? super R>) - Method in class org.apache.camel.component.reactive.streams.util.ConvertingPublisher
-
- subscribe(Subscriber<? super T>) - Method in class org.apache.camel.component.reactive.streams.util.MonoPublisher
-
- subscriber(String) - Method in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService
-
Creates a new route that pushes data to the endpoint URI and returns
the associated Subscriber
.
- subscriber(String, Class<T>) - Method in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService
-
Creates a new route that pushes data to the endpoint URI and returns
the associated Subscriber
.
- subscriber(String) - Method in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService
-
- subscriber(String, Class<T>) - Method in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService
-