Package | Description |
---|---|
org.apache.camel.component.reactive.streams | |
org.apache.camel.component.reactive.streams.engine |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamsBackpressureStrategy |
ReactiveStreamsEndpoint.getBackpressureStrategy() |
ReactiveStreamsBackpressureStrategy |
ReactiveStreamsComponent.getBackpressureStrategy() |
static ReactiveStreamsBackpressureStrategy |
ReactiveStreamsBackpressureStrategy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ReactiveStreamsBackpressureStrategy[] |
ReactiveStreamsBackpressureStrategy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
ReactiveStreamsEndpoint.setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
The backpressure strategy to use when pushing events to a slow subscriber.
|
void |
ReactiveStreamsComponent.setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
The backpressure strategy to use when pushing events to a slow subscriber.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamsBackpressureStrategy |
CamelSubscription.getBackpressureStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
CamelSubscription.setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy) |
Constructor and Description |
---|
CamelSubscription(String id,
ExecutorService workerPool,
CamelPublisher publisher,
String streamName,
ReactiveStreamsBackpressureStrategy backpressureStrategy,
org.reactivestreams.Subscriber<? super org.apache.camel.Exchange> subscriber) |
Apache Camel