Package glide.connectors.handlers
Class MessageHandler
- java.lang.Object
-
- glide.connectors.handlers.MessageHandler
-
public class MessageHandler extends java.lang.ObjectHandler for incoming push messages (subscriptions).
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classMessageHandler.PubSubMessageQueueAn asynchronous FIFO message queue forPubSubMessagebacked byConcurrentLinkedDeque.
-
Constructor Summary
Constructors Constructor Description MessageHandler(java.util.Optional<BaseSubscriptionConfiguration.MessageCallback> callback, java.util.Optional<java.lang.Object> context, BaseResponseResolver responseResolver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Optional<BaseSubscriptionConfiguration.MessageCallback>getCallback()A user callback to call for every incoming message, if given.java.util.Optional<java.lang.Object>getContext()An arbitrary user object to be passed to callback.MessageHandler.PubSubMessageQueuegetQueue()A message queue wrapper.BaseResponseResolvergetResponseResolver()Helper which extracts data from receivedResponseOuterClass.Responses from GLIDE.
-
-
-
Constructor Detail
-
MessageHandler
public MessageHandler(java.util.Optional<BaseSubscriptionConfiguration.MessageCallback> callback, java.util.Optional<java.lang.Object> context, BaseResponseResolver responseResolver)
-
-
Method Detail
-
getCallback
public java.util.Optional<BaseSubscriptionConfiguration.MessageCallback> getCallback()
A user callback to call for every incoming message, if given. If missing, messages are pushed into thequeue.
-
getContext
public java.util.Optional<java.lang.Object> getContext()
An arbitrary user object to be passed to callback.
-
getResponseResolver
public BaseResponseResolver getResponseResolver()
Helper which extracts data from receivedResponseOuterClass.Responses from GLIDE.
-
getQueue
public MessageHandler.PubSubMessageQueue getQueue()
A message queue wrapper.
-
-