com.hazelcast.map.impl.querycache.publisher

Class DefaultPublisherContext

java.lang.Object

com.hazelcast.map.impl.querycache.publisher.DefaultPublisherContext

All Implemented Interfaces:

PublisherContext

public class DefaultPublisherContext
extends Object
implements PublisherContext

Default implementation of PublisherContext.

See Also:

PublisherContext

Constructor Summary

Constructors

Constructor and Description
DefaultPublisherContext(QueryCacheContext context, NodeEngine nodeEngine, IFunction<String,String> listenerRegistrator)

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes this publisher context.
AccumulatorInfoSupplier	getAccumulatorInfoSupplier() Returns AccumulatorInfoSupplier for this context.
QueryCacheContext	getContext() Returns QueryCacheContext on this node.
IFunction<String,String>	getListenerRegistrator() Returns a helper function in order to register listener to IMap
MapListenerRegistry	getMapListenerRegistry() Returns MapListenerRegistry for this context.
MapPublisherRegistry	getMapPublisherRegistry() Returns MapPublisherRegistry for this context.
NodeEngine	getNodeEngine() Returns underlying NodeEngine for this node.
void	handleConnectedSubscriber(String uuid) Handles a reconnected subscriber.
void	handleDisconnectedSubscriber(String uuid) Handles a disconnected subscriber.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPublisherContext

public DefaultPublisherContext(QueryCacheContext context,
                               NodeEngine nodeEngine,
                               IFunction<String,String> listenerRegistrator)

Method Detail

getAccumulatorInfoSupplier

public AccumulatorInfoSupplier getAccumulatorInfoSupplier()

Description copied from interface: PublisherContext

Returns AccumulatorInfoSupplier for this context.

Specified by:

getAccumulatorInfoSupplier in interface PublisherContext

Returns:

AccumulatorInfoSupplier for this context.

See Also:

AccumulatorInfoSupplier

getMapPublisherRegistry

public MapPublisherRegistry getMapPublisherRegistry()

Description copied from interface: PublisherContext

Returns MapPublisherRegistry for this context.

Specified by:

getMapPublisherRegistry in interface PublisherContext

Returns:

MapPublisherRegistry for this context.

See Also:

MapPublisherRegistry

getMapListenerRegistry

public MapListenerRegistry getMapListenerRegistry()

Description copied from interface: PublisherContext

Returns MapListenerRegistry for this context.

Specified by:

getMapListenerRegistry in interface PublisherContext

Returns:

MapListenerRegistry for this context.

See Also:

MapListenerRegistry

getContext

public QueryCacheContext getContext()

Description copied from interface: PublisherContext

Returns QueryCacheContext on this node.

Specified by:

getContext in interface PublisherContext

Returns:

QueryCacheContext on this node.

getNodeEngine

public NodeEngine getNodeEngine()

Description copied from interface: PublisherContext

Returns underlying NodeEngine for this node.

Specified by:

getNodeEngine in interface PublisherContext

Returns:

underlying NodeEngine for this node.

getListenerRegistrator

public IFunction<String,String> getListenerRegistrator()

Description copied from interface: PublisherContext

Returns a helper function in order to register listener to IMap

Specified by:

getListenerRegistrator in interface PublisherContext

Returns:

a helper function in order to register listener to IMap

handleDisconnectedSubscriber

public void handleDisconnectedSubscriber(String uuid)

Description copied from interface: PublisherContext

Handles a disconnected subscriber. This method will be used to clean orphaned QueryCache resources.

Specified by:

handleDisconnectedSubscriber in interface PublisherContext

Parameters:

uuid - client or node UUID of subscriber.

handleConnectedSubscriber

public void handleConnectedSubscriber(String uuid)

Description copied from interface: PublisherContext

Handles a reconnected subscriber. This method will be used to stop actions taken in #handleDisconnectedSubscriber.

Specified by:

handleConnectedSubscriber in interface PublisherContext

Parameters:

uuid - client or node UUID of subscriber.

See Also:

PublisherContext.handleDisconnectedSubscriber(java.lang.String)

flush

public void flush()

Description copied from interface: PublisherContext

Flushes this publisher context. For example during graceful shutdown we need to flush all events in the registered accumulators of this context.

Specified by:

flush in interface PublisherContext