Package glide.connectors.handlers

Class MessageHandler

java.lang.Object

glide.connectors.handlers.MessageHandler

public class MessageHandler
extends java.lang.Object

Handler for incoming push messages (subscriptions).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageHandler.PubSubMessageQueue	An asynchronous FIFO message queue for PubSubMessage backed by ConcurrentLinkedDeque.

Constructor Summary

Constructors

Constructor	Description
MessageHandler(java.util.Optional<BaseSubscriptionConfiguration.MessageCallback> callback, java.util.Optional<java.lang.Object> context, BaseResponseResolver responseResolver)

Method Summary

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.PubSubMessageQueue	getQueue()	A message queue wrapper.
BaseResponseResolver	getResponseResolver()	Helper which extracts data from received ResponseOuterClass.Responses from GLIDE.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 the queue.

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 received ResponseOuterClass.Responses from GLIDE.

getQueue

public MessageHandler.PubSubMessageQueue getQueue()

A message queue wrapper.