Package | Description |
---|---|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Method and Description |
---|---|
static ChangeStreamRequest.ChangeStreamRequestBuilder |
ChangeStreamRequest.builder()
Obtain a shiny new
ChangeStreamRequest.ChangeStreamRequestBuilder and start defining your ChangeStreamRequest in this
fancy fluent way. |
static <T> ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.builder(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> listener)
Obtain a shiny new
ChangeStreamRequest.ChangeStreamRequestBuilder and start defining your ChangeStreamRequest in this
fancy fluent way. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.collation(Collation collation)
Set the collation to use.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.collection(String collectionName)
Set the name of the
MongoCollection to listen to. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.database(String databaseName)
Set the name of the
MongoDatabase to listen to. |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.filter(Aggregation aggregation)
Set the filter to apply.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.filter(org.bson.Document... pipeline)
Set the plain filter chain to apply.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
Set the
FullDocument lookup to FullDocument.UPDATE_LOOKUP . |
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.maxAwaitTime(Duration timeout)
Set the cursors maximum wait time on the server (for a new Document to be emitted).
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.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> |
ChangeStreamRequest.ChangeStreamRequestBuilder.resumeAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to continue emitting notifications.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.resumeAt(Instant clusterTime)
Set the cluster time at which to resume listening.
|
ChangeStreamRequest.ChangeStreamRequestBuilder<T> |
ChangeStreamRequest.ChangeStreamRequestBuilder.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> |
ChangeStreamRequest.ChangeStreamRequestBuilder.startAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to start emitting notifications.
|
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.