Uses of Interface
org.springframework.data.mongodb.core.messaging.SubscriptionRequest.RequestOptions
Package
Description
MongoDB specific messaging support for listening to eg.
-
Uses of SubscriptionRequest.RequestOptions in org.springframework.data.mongodb.core.messaging
Modifier and TypeInterfaceDescriptioninterface
SubscriptionRequest<S,
T, O extends SubscriptionRequest.RequestOptions> The actualSubscriptionRequest
sent to theMessageListenerContainer
.Modifier and TypeClassDescriptionstatic class
SubscriptionRequest.RequestOptions
implementation specific to aChangeStreamRequest
.static class
SubscriptionRequest.RequestOptions
implementation specific to aTailableCursorRequest
.Modifier and TypeMethodDescriptionSubscriptionRequest.RequestOptions.justCollection
(String collection) Create options with the provided collection.SubscriptionRequest.RequestOptions.justDatabase
(String database) Create options with the provided database.SubscriptionRequest.RequestOptions.none()
Create empty options.Create options with the provided database and collection.Modifier and TypeMethodDescriptionChangeStreamRequest.ChangeStreamRequestOptions.of
(SubscriptionRequest.RequestOptions options) TailableCursorRequest.TailableCursorRequestOptions.of
(SubscriptionRequest.RequestOptions options) Modifier and TypeMethodDescription<S,
T> Subscription DefaultMessageListenerContainer.register
(SubscriptionRequest<S, ? super T, ? extends SubscriptionRequest.RequestOptions> request, Class<T> bodyType) <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) Register a newSubscriptionRequest
in the container.<S,
T> Subscription MessageListenerContainer.register
(SubscriptionRequest<S, ? super T, ? extends SubscriptionRequest.RequestOptions> request, Class<T> bodyType, ErrorHandler errorHandler) Register a newSubscriptionRequest
in the container.default <T> Subscription
MessageListenerContainer.register
(SubscriptionRequest<T, Object, ? extends SubscriptionRequest.RequestOptions> request) Register a newSubscriptionRequest
in the container.ModifierConstructorDescriptionChangeStreamRequest
(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)