PublisherContext (Hazelcast Root 3.12-BETA-1 API)

All Known Implementing Classes:

DefaultPublisherContext
```
public interface PublisherContext
```
Context for a publisher. Responsible for providing functionality/services for NonStopPublisherAccumulator and BatchPublisherAccumulator.

Method Summary

All Methods Instance Methods Abstract Methods
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.

- Method Detail
  - getAccumulatorInfoSupplier
```
AccumulatorInfoSupplier getAccumulatorInfoSupplier()
```
    Returns AccumulatorInfoSupplier for this context.
    
    Returns:
    
    AccumulatorInfoSupplier for this context.
    
    See Also:
    
    AccumulatorInfoSupplier
  - getMapPublisherRegistry
```
MapPublisherRegistry getMapPublisherRegistry()
```
    Returns MapPublisherRegistry for this context.
    
    Returns:
    
    MapPublisherRegistry for this context.
    
    See Also:
    
    MapPublisherRegistry
  - getMapListenerRegistry
```
MapListenerRegistry getMapListenerRegistry()
```
    Returns MapListenerRegistry for this context.
    
    Returns:
    
    MapListenerRegistry for this context.
    
    See Also:
    
    MapListenerRegistry
  - getListenerRegistrator
```
IFunction<String,String> getListenerRegistrator()
```
    Returns a helper function in order to register listener to IMap
    
    Returns:
    
    a helper function in order to register listener to IMap
  - getContext
```
QueryCacheContext getContext()
```
    Returns QueryCacheContext on this node.
    
    Returns:
    
    QueryCacheContext on this node.
  - getNodeEngine
```
NodeEngine getNodeEngine()
```
    Returns underlying NodeEngine for this node.
    
    Returns:
    
    underlying NodeEngine for this node.
  - handleDisconnectedSubscriber
```
void handleDisconnectedSubscriber(String uuid)
```
    Handles a disconnected subscriber. This method will be used to clean orphaned QueryCache resources.
    
    Parameters:
    
    uuid - client or node UUID of subscriber.
  - handleConnectedSubscriber
```
void handleConnectedSubscriber(String uuid)
```
    Handles a reconnected subscriber. This method will be used to stop actions taken in #handleDisconnectedSubscriber.
    
    Parameters:
    
    uuid - client or node UUID of subscriber.
    
    See Also:
    
    handleDisconnectedSubscriber(java.lang.String)
  - flush
```
void flush()
```
    Flushes this publisher context. For example during graceful shutdown we need to flush all events in the registered accumulators of this context.

Interface PublisherContext

Method Summary

Method Detail

getAccumulatorInfoSupplier

getMapPublisherRegistry

getMapListenerRegistry

getListenerRegistrator

getContext

getNodeEngine

handleDisconnectedSubscriber

handleConnectedSubscriber

flush