com.hazelcast.map.impl.querycache

Interface QueryCacheEventService<E>

Type Parameters:

E - type of event to be published.

All Known Implementing Classes:

ClientQueryCacheEventService, NodeQueryCacheEventService

public interface QueryCacheEventService<E>

Event service abstraction to allow different type of implementations on query cache subscriber and query cache publisher sides. Runs locally on query-cache subscriber side which may be node or client. Responsible for registering/removing listeners and publishing events locally etc.

Method Summary

Modifier and Type	Method and Description
String	addListener(String mapName, String cacheName, MapListener listener) Adds a user-defined listener to a query-cache.
String	addListener(String mapName, String cacheName, MapListener listener, EventFilter filter) Adds a user-defined listener to a query-cache.
boolean	hasListener(String mapName, String cacheName) Returns true if this query-cache has at least one registered listener otherwise returns false.
String	listenPublisher(String mapName, String cacheName, ListenerAdapter listenerAdapter) Adds the listener to listen underlying IMap on all nodes.
void	publish(String mapName, String cacheName, E event, int orderKey) Publishes query-cache events locally.
boolean	removeListener(String mapName, String cacheName, String id) Removes listener from this event service.
void	sendEventToSubscriber(String name, Object eventData, int orderKey) Only sends events which wrap data to be put in a query cache.

Method Detail

publish

void publish(String mapName,
             String cacheName,
             E event,
             int orderKey)

Publishes query-cache events locally.

Parameters:

mapName - underlying map name of query cache.

cacheName - name of the query cache.

event - event to publish.

orderKey - use same order key for events which are required to be ordered.

listenPublisher

String listenPublisher(String mapName,
                       String cacheName,
                       ListenerAdapter listenerAdapter)

Adds the listener to listen underlying IMap on all nodes.

Parameters:

mapName - underlying map name of query cache.

cacheName - name of the query cache.

listenerAdapter - listener adapter for the query-cache.

Returns:

id of registered event listener

addListener

String addListener(String mapName,
                   String cacheName,
                   MapListener listener)

Adds a user-defined listener to a query-cache. This listener is registered as a local listener on subscriber side.

Parameters:

mapName - underlying IMap name of query-cache.

cacheName - name of the query-cache.

listener - listener for receiving events.

Returns:

id of registered event listener

addListener

String addListener(String mapName,
                   String cacheName,
                   MapListener listener,
                   EventFilter filter)

Adds a user-defined listener to a query-cache. This listener is registered as a local listener on subscriber side.

Parameters:

mapName - underlying IMap name of query-cache.

cacheName - name of the query-cache.

listener - listener for receiving events.

filter - used to filter events.

Returns:

id of registered event listener

removeListener

boolean removeListener(String mapName,
                       String cacheName,
                       String id)

Removes listener from this event service.

Parameters:

mapName - underlying IMap name of query-cache.

cacheName - name of the query cache.

id - id of listener.

Returns:

true if listener is removed successfully, false otherwise.

hasListener

boolean hasListener(String mapName,
                    String cacheName)

Returns true if this query-cache has at least one registered listener otherwise returns false.

Parameters:

mapName - underlying IMap name of query-cache.

cacheName - name of the query-cache.

Returns:

true if this query-cache has at least one registered listener otherwise returns false.

sendEventToSubscriber

void sendEventToSubscriber(String name,
                           Object eventData,
                           int orderKey)

Only sends events which wrap data to be put in a query cache.

Parameters:

name - listener name.

eventData - the event data.

orderKey - the order key for the event.