public static class TailableCursorRequest.TailableCursorRequestBuilder<T> extends Object
TailableCursorRequest
.TailableCursorRequest.TailableCursorRequestOptions
Modifier and Type | Method and Description |
---|---|
TailableCursorRequest<T> |
build() |
TailableCursorRequest.TailableCursorRequestBuilder<T> |
collection(String collectionName)
Set the name of the
MongoCollection to listen to. |
TailableCursorRequest.TailableCursorRequestBuilder<T> |
filter(Query filter)
Set the filter to apply.
|
TailableCursorRequest.TailableCursorRequestBuilder<T> |
publishTo(MessageListener<org.bson.Document,? super T> messageListener)
Set the
MessageListener event messages will be published to. |
public TailableCursorRequest.TailableCursorRequestBuilder<T> collection(String collectionName)
MongoCollection
to listen to.collectionName
- must not be null nor empty.public TailableCursorRequest.TailableCursorRequestBuilder<T> publishTo(MessageListener<org.bson.Document,? super T> messageListener)
MessageListener
event messages
will be published to.messageListener
- must not be null.public TailableCursorRequest.TailableCursorRequestBuilder<T> filter(Query filter)
filter
- the Query
to apply for filtering events. Must not be null.public TailableCursorRequest<T> build()
ChangeStreamRequest
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.