E
- type of event to be published.public interface QueryCacheEventService<E>
Modifier and Type | Method and Description |
---|---|
String |
addListener(String mapName,
String cacheId,
MapListener listener)
Adds a user-defined listener to a query-cache.
|
String |
addListener(String mapName,
String cacheId,
MapListener listener,
EventFilter filter)
Adds a user-defined listener to a query-cache.
|
String |
addPublisherListener(String mapName,
String cacheId,
ListenerAdapter listenerAdapter)
Adds the listener to listen underlying IMap on all nodes.
|
boolean |
hasListener(String mapName,
String cacheId)
Returns
true if this query-cache has at least one registered
user defined listener otherwise returns false . |
void |
publish(String mapName,
String cacheId,
E event,
int orderKey,
Extractors extractors)
Publishes query-cache events locally.
|
void |
removeAllListeners(String mapName,
String cacheId)
Removes all user defined listeners associated to supplied
cacheId |
boolean |
removeListener(String mapName,
String cacheId,
String listenerId)
Removes listener from this event service.
|
boolean |
removePublisherListener(String mapName,
String cacheId,
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.
|
void publish(String mapName, String cacheId, E event, int orderKey, Extractors extractors)
mapName
- underlying map name of query cachecacheId
- ID of the query cacheevent
- event to publishorderKey
- use same order key for events which are required to be orderedextractors
- extractors for the query cacheString addPublisherListener(String mapName, String cacheId, ListenerAdapter listenerAdapter)
mapName
- underlying map name of query cachecacheId
- ID of the query cachelistenerAdapter
- listener adapter for the query-cacheboolean removePublisherListener(String mapName, String cacheId, String listenerId)
mapName
- underlying map name which query cache listenscacheId
- ID of the query cachelistenerId
- ID of registered listenertrue
if listener is de-registered, false
otherwiseString addListener(String mapName, String cacheId, MapListener listener)
mapName
- underlying IMap name of query-cachecacheId
- ID of the query-cachelistener
- listener for receiving eventsString addListener(String mapName, String cacheId, MapListener listener, EventFilter filter)
mapName
- underlying IMap name of query-cachecacheId
- ID of the query-cachelistener
- listener for receiving eventsfilter
- used to filter eventsboolean removeListener(String mapName, String cacheId, String listenerId)
mapName
- underlying IMap name of query-cachecacheId
- ID of the query cachelistenerId
- registration ID of listenertrue
if listener is removed successfully, false
otherwisevoid removeAllListeners(String mapName, String cacheId)
cacheId
mapName
- underlying IMap name of query-cachecacheId
- ID of the query cacheboolean hasListener(String mapName, String cacheId)
true
if this query-cache has at least one registered
user defined listener otherwise returns false
.mapName
- underlying IMap name of query-cachecacheId
- ID of the query-cachetrue
if this query-cache has at least one registered listener
otherwise returns false
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.