Package | Description |
---|---|
org.springframework.data.mongodb.core.messaging |
MongoDB specific messaging support for listening to eg.
|
Modifier and Type | Class and 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. |
Modifier and Type | Method and 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 |
MessageListenerContainer.register(SubscriptionRequest<S,? super T,? extends SubscriptionRequest.RequestOptions> request,
Class<T> bodyType)
Register a new
SubscriptionRequest in the container. |
<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,
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. |
Subscription |
DefaultMessageListenerContainer.register(SubscriptionRequest request,
Task task) |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.