Interface SubscriptionRequest<S,T,O extends SubscriptionRequest.RequestOptions>
- All Known Implementing Classes:
ChangeStreamRequest
,TailableCursorRequest
public interface SubscriptionRequest<S,T,O extends SubscriptionRequest.RequestOptions>
The actual
The
SubscriptionRequest
sent to the MessageListenerContainer
. This wrapper type allows passing
in additional information
to the Container which can be used for creating the actual
Task
running. The
MessageListener
provides the callback interface when pushing messages
.- Since:
- 2.1
- Author:
- Christoph Strobl
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interface
Options for specifying the behaviour of theSubscriptionRequest
. -
Method Summary
Modifier and TypeMethodDescriptionMessageListener<S,
? super T> Obtain theMessageListener
to publishmessages
to.Get theSubscriptionRequest.RequestOptions
specifying the requests behaviour.
-
Method Details
-
getMessageListener
MessageListener<S,? super T> getMessageListener()Obtain theMessageListener
to publishmessages
to.- Returns:
- never null.
-
getRequestOptions
O getRequestOptions()Get theSubscriptionRequest.RequestOptions
specifying the requests behaviour.- Returns:
- never null.
-