Package org.cyclos.impl.utils

Class NoClusterPushNotificationHandlerImpl

java.lang.Object

org.cyclos.impl.utils.AbstractPushNotificationHandlerImpl

org.cyclos.impl.utils.NoClusterPushNotificationHandlerImpl

All Implemented Interfaces:

PushNotificationHandler

public class NoClusterPushNotificationHandlerImpl
extends AbstractPushNotificationHandlerImpl

A PushNotificationHandler used when there is no cluster

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	NoClusterPushNotificationHandlerImpl.EventBusSubscription	A PushNotificationListenerSubscription that filters EventBus events before sending them to the PushNotificationListener

Field Summary

Fields inherited from class org.cyclos.impl.utils.AbstractPushNotificationHandlerImpl

LOG

Constructor Summary

Constructors

Constructor	Description
NoClusterPushNotificationHandlerImpl()

Method Summary

Modifier and Type	Method	Description
protected void	addMissedEvent(PushNotificationListenerSubscription subscription, PushNotificationEvent<?> event)	Enqueues a missed event for the given subscription
protected void	clearMissedEvents(PushNotificationListenerSubscription subscription)	Removes any queued missing events for the given subscription
void	close(String id)	Closes a subscription.
void	destroy()
protected String	doSubscribe(String clientId, PushNotificationSubscriptionMatcher matcher, Consumer<PushNotificationEvent<?>> listener)	Must be implemented in order to physically subscribe an event listener
protected Long	getCloseAfter(PushNotificationListenerSubscription subscription)	Returns the time in millis after which the given subscription will be closed
protected ExecutorService	getExecutorService()
protected Collection<PushNotificationEvent<?>>	getMissedEvents(PushNotificationListenerSubscription subscription)	Returns the events that were missed on the given subscription
protected NoClusterPushNotificationHandlerImpl.EventBusSubscription	getSubscription(String subId)	Must be implemented in order to return details of a subscription for the given id.
NoClusterPushNotificationHandlerImpl.EventBusSubscription	getSubscriptionById(String id)
protected String	getSubscriptionIdForClientId(String clientId)	Must be implemented to return the subscription id associated with the given client id
protected boolean	hasMatchingSubscriptions(PushNotificationEventContext<?> context)	Must be implemented to return the matching subscriptions for a context
void	initialize()
protected String	newEventId()	Must be implemented to generate an event id
protected void	post(PushNotificationEvent<?> event)	Must be implemented to physically post the event
protected void	sessionInvalidated(String sessionToken)	Must be implemented in order to remove all traces of the given session token
protected void	setCloseAfter(PushNotificationListenerSubscription subscription, Long closeAfter)	Sets the given subscription to close after a given time in millis, or null if it shouldn't close automatically

Methods inherited from class org.cyclos.impl.utils.AbstractPushNotificationHandlerImpl

getExpirationOffset, isActuallyExpired, isTimedOut, processEvent, publish, renew, setExpirationOffset, setTimedOut, subscribe, timeout

Methods inherited from class java.lang.Object

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

Constructor Detail

NoClusterPushNotificationHandlerImpl

public NoClusterPushNotificationHandlerImpl()

Method Detail

close

public void close(String id)

Description copied from interface: PushNotificationHandler

Closes a subscription.

See Also:

ServiceFacade.closeSubscription(String)

destroy

@PreDestroy
public void destroy()

getSubscriptionById

public NoClusterPushNotificationHandlerImpl.EventBusSubscription getSubscriptionById(String id)

initialize

@PostConstruct
public void initialize()

addMissedEvent

protected void addMissedEvent(PushNotificationListenerSubscription subscription,
                              PushNotificationEvent<?> event)

Description copied from class: AbstractPushNotificationHandlerImpl

Enqueues a missed event for the given subscription

Specified by:

addMissedEvent in class AbstractPushNotificationHandlerImpl

clearMissedEvents

protected void clearMissedEvents(PushNotificationListenerSubscription subscription)

Description copied from class: AbstractPushNotificationHandlerImpl

Removes any queued missing events for the given subscription

Specified by:

clearMissedEvents in class AbstractPushNotificationHandlerImpl

doSubscribe

protected String doSubscribe(String clientId,
                             PushNotificationSubscriptionMatcher matcher,
                             Consumer<PushNotificationEvent<?>> listener)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented in order to physically subscribe an event listener

Specified by:

doSubscribe in class AbstractPushNotificationHandlerImpl

getCloseAfter

protected Long getCloseAfter(PushNotificationListenerSubscription subscription)

Description copied from class: AbstractPushNotificationHandlerImpl

Returns the time in millis after which the given subscription will be closed

Specified by:

getCloseAfter in class AbstractPushNotificationHandlerImpl

getExecutorService

protected ExecutorService getExecutorService()

Specified by:

getExecutorService in class AbstractPushNotificationHandlerImpl

getMissedEvents

protected Collection<PushNotificationEvent<?>> getMissedEvents(PushNotificationListenerSubscription subscription)

Description copied from class: AbstractPushNotificationHandlerImpl

Returns the events that were missed on the given subscription

Specified by:

getMissedEvents in class AbstractPushNotificationHandlerImpl

getSubscription

protected NoClusterPushNotificationHandlerImpl.EventBusSubscription getSubscription(String subId)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented in order to return details of a subscription for the given id. Returning null means the subscription is not valid

Specified by:

getSubscription in class AbstractPushNotificationHandlerImpl

getSubscriptionIdForClientId

protected String getSubscriptionIdForClientId(String clientId)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented to return the subscription id associated with the given client id

Specified by:

getSubscriptionIdForClientId in class AbstractPushNotificationHandlerImpl

hasMatchingSubscriptions

protected boolean hasMatchingSubscriptions(PushNotificationEventContext<?> context)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented to return the matching subscriptions for a context

Specified by:

hasMatchingSubscriptions in class AbstractPushNotificationHandlerImpl

newEventId

protected String newEventId()

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented to generate an event id

Specified by:

newEventId in class AbstractPushNotificationHandlerImpl

post

protected void post(PushNotificationEvent<?> event)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented to physically post the event

Specified by:

post in class AbstractPushNotificationHandlerImpl

sessionInvalidated

protected void sessionInvalidated(String sessionToken)

Description copied from class: AbstractPushNotificationHandlerImpl

Must be implemented in order to remove all traces of the given session token

Specified by:

sessionInvalidated in class AbstractPushNotificationHandlerImpl

setCloseAfter

protected void setCloseAfter(PushNotificationListenerSubscription subscription,
                             Long closeAfter)

Description copied from class: AbstractPushNotificationHandlerImpl

Sets the given subscription to close after a given time in millis, or null if it shouldn't close automatically

Specified by:

setCloseAfter in class AbstractPushNotificationHandlerImpl