public class TailableCursorRequest<T> extends Object implements SubscriptionRequest<org.bson.Document,T,SubscriptionRequest.RequestOptions>
SubscriptionRequest
implementation to be used to listen to query results in a
Capped Collection using a
Tailable Cursor.
The most trivial use case is subscribing to all events of a specific collection
.
TailableCursorRequest request = new TailableCursorRequest<>(System.out::println, () -> "collection-name");
TailableCursorRequest.TailableCursorRequestBuilder
offers a fluent API for creating TailableCursorRequest
with
TailableCursorRequest.TailableCursorRequestOptions
in one go.
TailableCursorRequest request = TailableCursorRequest.builder()
.collection("collection-name")
.publishTo(System.out::println)
.build();
Modifier and Type | Class and Description |
---|---|
static class |
TailableCursorRequest.TailableCursorRequestBuilder<T>
Builder for creating
TailableCursorRequest . |
static class |
TailableCursorRequest.TailableCursorRequestOptions
SubscriptionRequest.RequestOptions implementation specific to a TailableCursorRequest . |
SubscriptionRequest.RequestOptions
Constructor and Description |
---|
TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener,
SubscriptionRequest.RequestOptions options)
|
Modifier and Type | Method and Description |
---|---|
static TailableCursorRequest.TailableCursorRequestBuilder |
builder()
Obtain a shiny new
TailableCursorRequest.TailableCursorRequestBuilder and start defining options in this fancy fluent way. |
static <T> TailableCursorRequest.TailableCursorRequestBuilder<T> |
builder(MessageListener<org.bson.Document,? super T> listener)
Obtain a shiny new
TailableCursorRequest.TailableCursorRequestBuilder and start defining options in this fancy fluent way. |
MessageListener<org.bson.Document,? super T> |
getMessageListener()
Obtain the
MessageListener to publish messages to. |
TailableCursorRequest.TailableCursorRequestOptions |
getRequestOptions()
Get the
SubscriptionRequest.RequestOptions specifying the requests behaviour. |
public TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener, SubscriptionRequest.RequestOptions options)
messageListener
- must not be null.options
- must not be null.public MessageListener<org.bson.Document,? super T> getMessageListener()
SubscriptionRequest
MessageListener
to publish messages
to.getMessageListener
in interface SubscriptionRequest<org.bson.Document,T,SubscriptionRequest.RequestOptions>
public TailableCursorRequest.TailableCursorRequestOptions getRequestOptions()
SubscriptionRequest
SubscriptionRequest.RequestOptions
specifying the requests behaviour.getRequestOptions
in interface SubscriptionRequest<org.bson.Document,T,SubscriptionRequest.RequestOptions>
public static TailableCursorRequest.TailableCursorRequestBuilder builder()
TailableCursorRequest.TailableCursorRequestBuilder
and start defining options in this fancy fluent way. Just
don't forget to call build()
when your're done.TailableCursorRequest.TailableCursorRequestBuilder
.public static <T> TailableCursorRequest.TailableCursorRequestBuilder<T> builder(MessageListener<org.bson.Document,? super T> listener)
TailableCursorRequest.TailableCursorRequestBuilder
and start defining options in this fancy fluent way. Just
don't forget to call build()
when your're done.TailableCursorRequest.TailableCursorRequestBuilder
.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.