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.

Related Packages

Package	Description
org.springframework.data.mongodb.core	MongoDB core support.

Class	Description
Cancelable	Cancelable allows stopping long running tasks and freeing underlying resources.
ChangeStreamRequest<T>	SubscriptionRequest implementation to be used for listening to Change Streams via a MessageListenerContainer using the synchronous MongoDB Java driver.
ChangeStreamRequest.ChangeStreamRequestBuilder<T>	Builder for creating ChangeStreamRequest.
ChangeStreamRequest.ChangeStreamRequestOptions	SubscriptionRequest.RequestOptions implementation specific to a ChangeStreamRequest.
DefaultMessageListenerContainer	Simple Executor based MessageListenerContainer implementation for running tasks like 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.
Message.MessageProperties
Message.MessageProperties.MessagePropertiesBuilder	Builder for Message.MessageProperties.
MessageListener<S,T>	Listener interface to receive delivery of Messages.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
Subscription	The Subscription is the link between the SubscriptionRequest and the actual running Task.
SubscriptionRequest<S, T, O extends SubscriptionRequest.RequestOptions>	The actual SubscriptionRequest sent to the MessageListenerContainer.
SubscriptionRequest.RequestOptions	Options for specifying the behaviour of the SubscriptionRequest.
TailableCursorRequest<T>	SubscriptionRequest implementation to be used to listen to query results in a Capped Collection using a Tailable Cursor.
TailableCursorRequest.TailableCursorRequestBuilder<T>	Builder for creating TailableCursorRequest.
TailableCursorRequest.TailableCursorRequestOptions	SubscriptionRequest.RequestOptions implementation specific to a TailableCursorRequest.
TailableCursorRequest.TailableCursorRequestOptions.TailableCursorRequestOptionsBuilder	Builder for creating TailableCursorRequest.TailableCursorRequestOptions.
Task	The actual Task to run within the MessageListenerContainer.
Task.State	The Task.State defining the lifecycle phase the actual Task.