public class CamelPublisher extends Object implements org.reactivestreams.Publisher<org.apache.camel.Exchange>, AutoCloseable
Constructor and Description |
---|
CamelPublisher(ExecutorService workerPool,
org.apache.camel.CamelContext context,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
attachProducer(ReactiveStreamsProducer producer) |
void |
close() |
void |
detachProducer() |
List<CamelSubscription> |
getSubscriptions() |
void |
publish(org.apache.camel.Exchange data) |
void |
subscribe(org.reactivestreams.Subscriber<? super org.apache.camel.Exchange> subscriber) |
void |
unsubscribe(CamelSubscription subscription) |
public CamelPublisher(ExecutorService workerPool, org.apache.camel.CamelContext context, String name)
public void subscribe(org.reactivestreams.Subscriber<? super org.apache.camel.Exchange> subscriber)
subscribe
in interface org.reactivestreams.Publisher<org.apache.camel.Exchange>
public void unsubscribe(CamelSubscription subscription)
public void publish(org.apache.camel.Exchange data)
public void attachProducer(ReactiveStreamsProducer producer)
public void detachProducer()
public void close() throws Exception
close
in interface AutoCloseable
Exception
public List<CamelSubscription> getSubscriptions()
Apache Camel