com.hazelcast.map.impl.querycache.subscriber

Class NodeQueryCacheEventService

java.lang.Object

com.hazelcast.map.impl.querycache.subscriber.NodeQueryCacheEventService

All Implemented Interfaces:

QueryCacheEventService<EventData>

public class NodeQueryCacheEventService
extends Object
implements QueryCacheEventService<EventData>

Node side event service implementation for query cache.

See Also:

QueryCacheEventService

Constructor Summary

Constructors

Constructor and Description
NodeQueryCacheEventService(MapServiceContext mapServiceContext)

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, EventData eventData, int orderKey) Publishes query-cache events locally.
boolean	removeListener(String mapName, String cacheName, String id) Removes listener from this event service.
boolean	removePublisherListener(String mapName, String listenerId) Removes listener from underlying IMap
void	sendEventToSubscriber(String name, Object eventData, int orderKey) Only sends events which wrap data to be put in a query cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeQueryCacheEventService

public NodeQueryCacheEventService(MapServiceContext mapServiceContext)

Method Detail

publish

public void publish(String mapName,
                    String cacheName,
                    EventData eventData,
                    int orderKey)

Description copied from interface: QueryCacheEventService

Publishes query-cache events locally.

Specified by:

publish in interface QueryCacheEventService<EventData>

Parameters:

mapName - underlying map name of query cache.

cacheName - name of the query cache.

eventData - event to publish.

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

addListener

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

Description copied from interface: QueryCacheEventService

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

Specified by:

addListener in interface QueryCacheEventService<EventData>

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

listenPublisher

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

Description copied from interface: QueryCacheEventService

Adds the listener to listen underlying IMap on all nodes.

Specified by:

listenPublisher in interface QueryCacheEventService<EventData>

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

removePublisherListener

public boolean removePublisherListener(String mapName,
                                       String listenerId)

Description copied from interface: QueryCacheEventService

Removes listener from underlying IMap

Specified by:

removePublisherListener in interface QueryCacheEventService<EventData>

Parameters:

mapName - underlying map name which query cache listens.

listenerId - id of registered listener

Returns:

true if listener is de-registered, false otherwise.

addListener

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

Description copied from interface: QueryCacheEventService

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

Specified by:

addListener in interface QueryCacheEventService<EventData>

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

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

Description copied from interface: QueryCacheEventService

Removes listener from this event service.

Specified by:

removeListener in interface QueryCacheEventService<EventData>

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

public boolean hasListener(String mapName,
                           String cacheName)

Description copied from interface: QueryCacheEventService

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

Specified by:

hasListener in interface QueryCacheEventService<EventData>

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

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

Description copied from interface: QueryCacheEventService

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

Specified by:

sendEventToSubscriber in interface QueryCacheEventService<EventData>

Parameters:

name - listener name.

eventData - the event data.

orderKey - the order key for the event.