public static class ChangeStreamRequest.ChangeStreamRequestBuilder<T> extends Object
ChangeStreamRequest
.ChangeStreamOptions
Modifier and Type | Method and Description |
---|---|
ChangeStreamRequest<T> |
build() |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
collation(Collation collation)
Set the collation to use.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
collection(String collectionName)
Set the name of the
MongoCollection to listen to. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
database(String databaseName)
Set the name of the
MongoDatabase to listen to. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
filter(Aggregation aggregation)
Set the filter to apply.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
filter(org.bson.Document... pipeline)
Set the plain filter chain to apply.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
Set the
FullDocument lookup to FullDocument.UPDATE_LOOKUP . |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
maxAwaitTime(Duration timeout)
Set the cursors maximum wait time on the server (for a new Document to be emitted).
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
publishTo(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> messageListener)
Set the
MessageListener event messages will be published to. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
resumeAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to continue emitting notifications.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
resumeAt(Instant clusterTime)
Set the cluster time at which to resume listening.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
resumeToken(org.bson.BsonValue resumeToken)
Set the resume token (typically a
BsonDocument containing a binary
token ) after which to start with listening. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
startAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to start emitting notifications.
|
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> database(String databaseName)
MongoDatabase
to listen to.databaseName
- must not be null nor empty.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> collection(String collectionName)
MongoCollection
to listen to.collectionName
- must not be null nor empty.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> publishTo(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> messageListener)
MessageListener
event messages
will be published to.messageListener
- must not be null.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> filter(Aggregation aggregation)
fullDocument
. However operationType, ns,
documentKey and fullDocument are reserved words that will be omitted, and therefore taken
as given, during the mapping procedure. You may want to have a look at the
structure of Change Events.
Use TypedAggregation
to ensure filter expressions are
mapped to domain type fields.aggregation
- the Aggregation pipeline
to apply for filtering events. Must not be
null.ChangeStreamOptions.getFilter()
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.filter(Aggregation)
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> filter(org.bson.Document... pipeline)
pipeline
- must not be null nor contain null values.ChangeStreamOptions.getFilter()
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> collation(Collation collation)
collation
- must not be null nor empty.ChangeStreamOptions.getCollation()
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.collation(Collation)
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> resumeToken(org.bson.BsonValue resumeToken)
BsonDocument
containing a binary
token
) after which to start with listening.resumeToken
- must not be null.ChangeStreamOptions.getResumeToken()
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeToken(org.bson.BsonValue)
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> resumeAt(Instant clusterTime)
clusterTime
- must not be null.ChangeStreamOptions.getResumeTimestamp()
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAt(java.time.Instant)
public ChangeStreamRequest.ChangeStreamRequestBuilder<T> resumeAfter(org.bson.BsonValue resumeToken)
resumeToken
- must not be null.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> startAfter(org.bson.BsonValue resumeToken)
resumeToken
- must not be null.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
FullDocument
lookup to FullDocument.UPDATE_LOOKUP
.public ChangeStreamRequest.ChangeStreamRequestBuilder<T> maxAwaitTime(Duration timeout)
timeout
- must not be null.public ChangeStreamRequest<T> build()
ChangeStreamRequest
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.