public class DefaultPublisherContext extends Object implements PublisherContext
PublisherContext
.PublisherContext
Constructor and Description |
---|
DefaultPublisherContext(QueryCacheContext context,
NodeEngine nodeEngine,
IFunction<String,String> listenerRegistrator) |
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.
|
public DefaultPublisherContext(QueryCacheContext context, NodeEngine nodeEngine, IFunction<String,String> listenerRegistrator)
public AccumulatorInfoSupplier getAccumulatorInfoSupplier()
PublisherContext
AccumulatorInfoSupplier
for this context.getAccumulatorInfoSupplier
in interface PublisherContext
AccumulatorInfoSupplier
for this context.AccumulatorInfoSupplier
public MapPublisherRegistry getMapPublisherRegistry()
PublisherContext
MapPublisherRegistry
for this context.getMapPublisherRegistry
in interface PublisherContext
MapPublisherRegistry
for this context.MapPublisherRegistry
public MapListenerRegistry getMapListenerRegistry()
PublisherContext
MapListenerRegistry
for this context.getMapListenerRegistry
in interface PublisherContext
MapListenerRegistry
for this context.MapListenerRegistry
public QueryCacheContext getContext()
PublisherContext
QueryCacheContext
on this node.getContext
in interface PublisherContext
QueryCacheContext
on this node.public NodeEngine getNodeEngine()
PublisherContext
NodeEngine
for this node.getNodeEngine
in interface PublisherContext
NodeEngine
for this node.public IFunction<String,String> getListenerRegistrator()
PublisherContext
IMap
getListenerRegistrator
in interface PublisherContext
IMap
public void handleDisconnectedSubscriber(String uuid)
PublisherContext
QueryCache
resources.handleDisconnectedSubscriber
in interface PublisherContext
uuid
- client or node UUID of subscriber.public void handleConnectedSubscriber(String uuid)
PublisherContext
#handleDisconnectedSubscriber
.handleConnectedSubscriber
in interface PublisherContext
uuid
- client or node UUID of subscriber.PublisherContext.handleDisconnectedSubscriber(java.lang.String)
public void flush()
PublisherContext
flush
in interface PublisherContext
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.