public class CamelSubscription extends Object implements org.reactivestreams.Subscription
Constructor and Description |
---|
CamelSubscription(String id,
ExecutorService workerPool,
CamelPublisher publisher,
String streamName,
ReactiveStreamsBackpressureStrategy backpressureStrategy,
org.reactivestreams.Subscriber<? super org.apache.camel.Exchange> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
protected void |
checkAndFlush() |
protected void |
discardBuffer(List<org.apache.camel.Exchange> remaining) |
protected void |
flush() |
ReactiveStreamsBackpressureStrategy |
getBackpressureStrategy() |
long |
getBufferSize() |
String |
getId() |
void |
publish(org.apache.camel.Exchange message) |
void |
request(long l) |
void |
setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy) |
void |
signalCompletion() |
public CamelSubscription(String id, ExecutorService workerPool, CamelPublisher publisher, String streamName, ReactiveStreamsBackpressureStrategy backpressureStrategy, org.reactivestreams.Subscriber<? super org.apache.camel.Exchange> subscriber)
public void request(long l)
request
in interface org.reactivestreams.Subscription
protected void checkAndFlush()
protected void flush()
public void cancel()
cancel
in interface org.reactivestreams.Subscription
protected void discardBuffer(List<org.apache.camel.Exchange> remaining)
public void publish(org.apache.camel.Exchange message)
public void setBackpressureStrategy(ReactiveStreamsBackpressureStrategy backpressureStrategy)
public long getBufferSize()
public ReactiveStreamsBackpressureStrategy getBackpressureStrategy()
public String getId()
Apache Camel