public class DelayedMonoPublisher<T> extends Object implements org.reactivestreams.Publisher<T>
Constructor and Description |
---|
DelayedMonoPublisher(ExecutorService workerPool) |
Modifier and Type | Method and Description |
---|---|
T |
getData() |
Throwable |
getException() |
void |
setData(T data) |
void |
setException(Throwable exception) |
void |
subscribe(org.reactivestreams.Subscriber<? super T> subscriber) |
public DelayedMonoPublisher(ExecutorService workerPool)
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
subscribe
in interface org.reactivestreams.Publisher<T>
public T getData()
public void setData(T data)
public Throwable getException()
public void setException(Throwable exception)
Apache Camel