Uses of Class
org.springframework.data.mongodb.core.ChangeStreamOptions
Package
Description
MongoDB core support.
MongoDB specific messaging support for listening to eg.
-
Uses of ChangeStreamOptions in org.springframework.data.mongodb.core
Modifier and TypeMethodDescriptionChangeStreamOptions.ChangeStreamOptionsBuilder.build()
static ChangeStreamOptions
ChangeStreamOptions.empty()
Modifier and TypeMethodDescription<T> reactor.core.publisher.Flux<ChangeStreamEvent<T>>
ReactiveMongoOperations.changeStream
(String database, String collectionName, ChangeStreamOptions options, Class<T> targetType) Subscribe to a MongoDB Change Stream via the reactive infrastructure.default <T> reactor.core.publisher.Flux<ChangeStreamEvent<T>>
ReactiveMongoOperations.changeStream
(String collectionName, ChangeStreamOptions options, Class<T> targetType) Subscribe to a MongoDB Change Stream for all events in the given collection via the reactive infrastructure.default <T> reactor.core.publisher.Flux<ChangeStreamEvent<T>>
ReactiveMongoOperations.changeStream
(ChangeStreamOptions options, Class<T> targetType) Subscribe to a MongoDB Change Stream for all events in the configured default database via the reactive infrastructure.<T> reactor.core.publisher.Flux<ChangeStreamEvent<T>>
ReactiveMongoTemplate.changeStream
(String database, String collectionName, ChangeStreamOptions options, Class<T> targetType) -
Uses of ChangeStreamOptions in org.springframework.data.mongodb.core.messaging
Modifier and TypeMethodDescriptionChangeStreamRequest.ChangeStreamRequestOptions.getChangeStreamOptions()
Get theChangeStreamOptions
defined.ModifierConstructorDescriptionChangeStreamRequestOptions
(String databaseName, String collectionName, Duration maxAwaitTime, ChangeStreamOptions options) Create newChangeStreamRequest.ChangeStreamRequestOptions
.ChangeStreamRequestOptions
(String databaseName, String collectionName, ChangeStreamOptions options) Create newChangeStreamRequest.ChangeStreamRequestOptions
.