Uses of Interface
org.springframework.data.mongodb.core.messaging.SubscriptionRequest

Packages that use SubscriptionRequest

Package	Description
org.springframework.data.mongodb.core.messaging	MongoDB specific messaging support for listening to eg.

Uses of SubscriptionRequest in org.springframework.data.mongodb.core.messaging

Classes in org.springframework.data.mongodb.core.messaging that implement SubscriptionRequest

Modifier and Type	Class	Description
class	ChangeStreamRequest<T>	SubscriptionRequest implementation to be used for listening to Change Streams via a MessageListenerContainer using the synchronous MongoDB Java driver.
class	TailableCursorRequest<T>	SubscriptionRequest implementation to be used to listen to query results in a Capped Collection using a Tailable Cursor.

Methods in org.springframework.data.mongodb.core.messaging with parameters of type SubscriptionRequest

Modifier and Type	Method	Description
Optional<Subscription>	DefaultMessageListenerContainer.lookup(SubscriptionRequest<?,?,?> request)
Optional<Subscription>	MessageListenerContainer.lookup(SubscriptionRequest<?,?,?> request)	Lookup the given SubscriptionRequest within the container and return the associated Subscription if present.
<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)
Subscription	DefaultMessageListenerContainer.register(SubscriptionRequest request, Task task)
<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	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.