Package | Description |
---|---|
org.springframework.data.mongodb.core |
MongoDB core support.
|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Method and Description |
---|---|
ChangeStreamOptions |
ChangeStreamOptions.ChangeStreamOptionsBuilder.build() |
static ChangeStreamOptions |
ChangeStreamOptions.empty() |
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
<T> reactor.core.publisher.Flux<ChangeStreamEvent<T>> |
ReactiveMongoTemplate.changeStream(String database,
String collectionName,
ChangeStreamOptions options,
Class<T> targetType) |
<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.
|
Modifier and Type | Method and Description |
---|---|
ChangeStreamOptions |
ChangeStreamRequest.ChangeStreamRequestOptions.getChangeStreamOptions()
Get the
ChangeStreamOptions defined. |
Constructor and Description |
---|
ChangeStreamRequestOptions(String databaseName,
String collectionName,
ChangeStreamOptions options)
Create new
ChangeStreamRequest.ChangeStreamRequestOptions . |
ChangeStreamRequestOptions(String databaseName,
String collectionName,
Duration maxAwaitTime,
ChangeStreamOptions options)
Create new
ChangeStreamRequest.ChangeStreamRequestOptions . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.