Package org.springframework.data.mongodb.core.messaging
@NullMarked
package org.springframework.data.mongodb.core.messaging
MongoDB specific messaging support for listening to eg.
Change Streams.
-
ClassDescriptionCancelable allows stopping long running tasks and freeing underlying resources.
SubscriptionRequestimplementation to be used for listening to Change Streams via aMessageListenerContainerusing the synchronous MongoDB Java driver.Builder for creatingChangeStreamRequest.SubscriptionRequest.RequestOptionsimplementation specific to aChangeStreamRequest.SimpleExecutorbasedMessageListenerContainerimplementation for runningtaskslike listening to MongoDB Change Streams and tailable cursors.Message<S,T> General message abstraction for any type of Event / Message published by MongoDB server to the client.Builder forMessage.MessageProperties.MessageListener<S,T> Listener interface to receive delivery ofMessages.Internal abstraction used by the framework representing a message listener container.SubscriptionRequest<S, T, O extends SubscriptionRequest.RequestOptions>The actualSubscriptionRequestsent to theMessageListenerContainer.Options for specifying the behaviour of theSubscriptionRequest.SubscriptionRequestimplementation to be used to listen to query results in a Capped Collection using a Tailable Cursor.Builder for creatingTailableCursorRequest.SubscriptionRequest.RequestOptionsimplementation specific to aTailableCursorRequest.Builder for creatingTailableCursorRequest.TailableCursorRequestOptions.The actualTaskto run within theMessageListenerContainer.TheTask.Statedefining the lifecycle phase the actualTask.