public class TailableCursorRequest<T> extends Object implements SubscriptionRequest<org.bson.Document,T,SubscriptionRequest.RequestOptions>
SubscriptionRequest
collection
TailableCursorRequest request = new TailableCursorRequest<>(System.out::println, () -> "collection-name");
TailableCursorRequest.TailableCursorRequestBuilder
TailableCursorRequest
TailableCursorRequest.TailableCursorRequestOptions
TailableCursorRequest request = TailableCursorRequest.builder() .collection("collection-name") .publishTo(System.out::println) .build();
static class
TailableCursorRequest.TailableCursorRequestBuilder<T>
SubscriptionRequest.RequestOptions
TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener, SubscriptionRequest.RequestOptions options)
messages
MessageListener
static TailableCursorRequest.TailableCursorRequestBuilder
builder()
static <T> TailableCursorRequest.TailableCursorRequestBuilder<T>
builder(MessageListener<org.bson.Document,? super T> listener)
MessageListener<org.bson.Document,? super T>
getMessageListener()
getRequestOptions()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener, SubscriptionRequest.RequestOptions options)
messageListener
options
public MessageListener<org.bson.Document,? super T> getMessageListener()
getMessageListener
SubscriptionRequest<org.bson.Document,T,SubscriptionRequest.RequestOptions>
public TailableCursorRequest.TailableCursorRequestOptions getRequestOptions()
getRequestOptions
public static TailableCursorRequest.TailableCursorRequestBuilder builder()
build()
public static <T> TailableCursorRequest.TailableCursorRequestBuilder<T> builder(MessageListener<org.bson.Document,? super T> listener)
Impressum und Datenschutz Copyright ©2018 eir.me