public class Subscription<T> extends Object implements IObservable<T>, CleanCloseable
Modifier and Type | Class and Description |
---|---|
static class |
Subscription.DocumentProcessedEventArgs |
static class |
Subscription.LastProcessedEtagEventArgs |
protected static final ILog logger
public CleanCloseable subscribe(IObserver<T> observer)
subscribe
in interface IObservable<T>
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
public IObservable<T> where(Predicate<T> predicate)
where
in interface IObservable<T>
public void addBeforeBatchHandler(EventHandler<VoidArgs> handler)
public void removeBeforeBatchHandler(EventHandler<VoidArgs> handler)
public void addAfterBatchHandler(EventHandler<Subscription.DocumentProcessedEventArgs> handler)
public void removeAfterBatchHandler(EventHandler<Subscription.DocumentProcessedEventArgs> handler)
public void addBeforeAcknowledgmentHandler(EventHandler<VoidArgs> handler)
public void removeBeforeAcknowledgmentHandler(EventHandler<VoidArgs> handler)
public void addAfterAcknowledgmentHandler(EventHandler<Subscription.LastProcessedEtagEventArgs> handler)
public void removeAfterAcknowledgmentHandler(EventHandler<Subscription.LastProcessedEtagEventArgs> handler)
public boolean isConnectionClosed()
public boolean isErroredBecauseOfSubscriber()
public Throwable getSubscriptionConnectionException()
public Throwable getLastSubscriberException()
Copyright © 2016. All Rights Reserved.