Package | Description |
---|---|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SubscriptionRequest<S,T,O extends SubscriptionRequest.RequestOptions>
The actual
SubscriptionRequest sent to the MessageListenerContainer . |
Modifier and Type | Class and Description |
---|---|
static class |
ChangeStreamRequest.ChangeStreamRequestOptions
SubscriptionRequest.RequestOptions implementation specific to a ChangeStreamRequest . |
static class |
TailableCursorRequest.TailableCursorRequestOptions
SubscriptionRequest.RequestOptions implementation specific to a TailableCursorRequest . |
Modifier and Type | Method and Description |
---|---|
static SubscriptionRequest.RequestOptions |
SubscriptionRequest.RequestOptions.justCollection(String collection)
Create options with the provided collection.
|
static SubscriptionRequest.RequestOptions |
SubscriptionRequest.RequestOptions.justDatabase(String database)
Create options with the provided database.
|
static SubscriptionRequest.RequestOptions |
SubscriptionRequest.RequestOptions.none()
Create empty options.
|
static SubscriptionRequest.RequestOptions |
SubscriptionRequest.RequestOptions.of(String database,
String collection)
Create options with the provided database and collection.
|
Modifier and Type | Method and Description |
---|---|
static TailableCursorRequest.TailableCursorRequestOptions |
TailableCursorRequest.TailableCursorRequestOptions.of(SubscriptionRequest.RequestOptions options) |
static ChangeStreamRequest.ChangeStreamRequestOptions |
ChangeStreamRequest.ChangeStreamRequestOptions.of(SubscriptionRequest.RequestOptions options) |
Modifier and Type | Method and Description |
---|---|
<S,T> Subscription |
DefaultMessageListenerContainer.register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request,
Class<T> bodyType) |
<S,T> Subscription |
MessageListenerContainer.register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request,
Class<T> bodyType)
Register a new
SubscriptionRequest in the container. |
<S,T> Subscription |
DefaultMessageListenerContainer.register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request,
Class<T> bodyType,
ErrorHandler errorHandler) |
<S,T> Subscription |
MessageListenerContainer.register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request,
Class<T> bodyType,
ErrorHandler errorHandler)
Register a new
SubscriptionRequest in the container. |
default <T> Subscription |
MessageListenerContainer.register(SubscriptionRequest<T,Object,? extends SubscriptionRequest.RequestOptions> request)
Register a new
SubscriptionRequest in the container. |
Constructor and Description |
---|
ChangeStreamRequest(MessageListener<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,? super T> messageListener,
SubscriptionRequest.RequestOptions options)
|
TailableCursorRequest(MessageListener<org.bson.Document,? super T> messageListener,
SubscriptionRequest.RequestOptions options)
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.