public class ReactiveStreamsCamelSubscriber extends Object implements org.reactivestreams.Subscriber<org.apache.camel.Exchange>, Closeable
Constructor and Description |
---|
ReactiveStreamsCamelSubscriber(String name) |
Modifier and Type | Method and Description |
---|---|
void |
attachConsumer(ReactiveStreamsConsumer consumer) |
void |
close() |
void |
detachConsumer() |
ReactiveStreamsConsumer |
getConsumer() |
long |
getInflightCount() |
long |
getRequested() |
void |
onComplete() |
void |
onError(Throwable throwable) |
void |
onNext(org.apache.camel.Exchange exchange) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
protected void |
refill() |
public ReactiveStreamsCamelSubscriber(String name)
public void attachConsumer(ReactiveStreamsConsumer consumer)
public ReactiveStreamsConsumer getConsumer()
public void detachConsumer()
public void onSubscribe(org.reactivestreams.Subscription subscription)
onSubscribe
in interface org.reactivestreams.Subscriber<org.apache.camel.Exchange>
public void onNext(org.apache.camel.Exchange exchange)
onNext
in interface org.reactivestreams.Subscriber<org.apache.camel.Exchange>
protected void refill()
public void onError(Throwable throwable)
onError
in interface org.reactivestreams.Subscriber<org.apache.camel.Exchange>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<org.apache.camel.Exchange>
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public long getRequested()
public long getInflightCount()
Apache Camel