@NonNullApi

Package org.springframework.data.mongodb.core.messaging

MongoDB specific messaging support for listening to eg.

See: Description

Interface Summary

Interface	Description
Cancelable	Cancelable allows stopping long running tasks and freeing underlying resources.
Message<S,T>	General message abstraction for any type of Event / Message published by MongoDB server to the client.
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.
Task	The actual Task to run within the MessageListenerContainer.

Class Summary

Class	Description
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.MessageProperties
Message.MessageProperties.MessagePropertiesBuilder	Builder for Message.MessageProperties.
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.

Enum Summary

Enum	Description
Task.State	The Task.State defining the lifecycle phase the actual Task.

Package org.springframework.data.mongodb.core.messaging Description

MongoDB specific messaging support for listening to eg. Change Streams.