com.hazelcast.cache.impl

Class CacheEventListenerAdaptor<K,V>

java.lang.Object

com.hazelcast.cache.impl.CacheEventListenerAdaptor<K,V>

Type Parameters:

K - the type of key.

V - the type of value.

All Implemented Interfaces:

CacheEntryListenerProvider<K,V>, CacheEventListener, EventFilter, ListenerWrapperEventFilter, NotifiableEventListener<CacheService>, Serializable

public class CacheEventListenerAdaptor<K,V>
extends Object
implements CacheEventListener, CacheEntryListenerProvider<K,V>, NotifiableEventListener<CacheService>, ListenerWrapperEventFilter, Serializable

This implementation of CacheEventListener uses the adapter pattern for wrapping all cache event listener types into a single listener.

JCache has multiple CacheEntryListener sub-interfaces for each event type. This adapter implementation delegates to the correct subtype using the event type.

Another responsibility of this implementation is filtering events by using the already configured event filters.

See Also:

CacheEntryCreatedListener, CacheEntryUpdatedListener, CacheEntryRemovedListener, CacheEntryExpiredListener, CacheEntryEventFilter, Serialized Form

Constructor Summary

Constructors

Constructor and Description
CacheEventListenerAdaptor(ICache<K,V> source, javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration, SerializationService serializationService, HazelcastInstance hazelcastInstance)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	eval(Object event)
javax.cache.event.CacheEntryListener<K,V>	getCacheEntryListener() Gets wrapped CacheEntryListener
Object	getListener() Gets the wrapped listener.
void	handle(int type, Collection<CacheEventData> keys, int completionId)
void	handleEvent(Object eventObject) Cache Event handling function.
void	onDeregister(CacheService cacheService, String serviceName, String topic, EventRegistration registration) Called when this listener deregistered from EventService.
void	onRegister(CacheService cacheService, String serviceName, String topic, EventRegistration registration) Called when this listener registered to EventService.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheEventListenerAdaptor

public CacheEventListenerAdaptor(ICache<K,V> source,
                         javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cacheEntryListenerConfiguration,
                         SerializationService serializationService,
                         HazelcastInstance hazelcastInstance)

Method Detail

getCacheEntryListener

public javax.cache.event.CacheEntryListener<K,V> getCacheEntryListener()

Description copied from interface: CacheEntryListenerProvider

Gets wrapped CacheEntryListener

Specified by:

getCacheEntryListener in interface CacheEntryListenerProvider<K,V>

Returns:

the wrapped CacheEntryListener

handleEvent

public void handleEvent(Object eventObject)

Description copied from interface: CacheEventListener

Cache Event handling function.

Specified by:

handleEvent in interface CacheEventListener

Parameters:

eventObject - Event data object, can be one of CacheEventSet or CacheEventData classes.

See Also:

Event Types that can be handled.

handle

public void handle(int type,
          Collection<CacheEventData> keys,
          int completionId)

onRegister

public void onRegister(CacheService cacheService,
              String serviceName,
              String topic,
              EventRegistration registration)

Description copied from interface: NotifiableEventListener

Called when this listener registered to EventService.

Specified by:

onRegister in interface NotifiableEventListener<CacheService>

Parameters:

cacheService - the service instance that event belongs to

serviceName - name of the service that event belongs to

topic - name of the topic that event belongs to

registration - the EventRegistration instance that holds information about the registration

onDeregister

public void onDeregister(CacheService cacheService,
                String serviceName,
                String topic,
                EventRegistration registration)

Description copied from interface: NotifiableEventListener

Called when this listener deregistered from EventService.

Specified by:

onDeregister in interface NotifiableEventListener<CacheService>

Parameters:

cacheService - the service instance that event belongs to

serviceName - name of the service that event belongs to

topic - name of the topic that event belongs to

registration - the EventRegistration instance that holds information about the registration

eval

public boolean eval(Object event)

Specified by:

eval in interface EventFilter

getListener

public Object getListener()

Description copied from interface: ListenerWrapperEventFilter

Gets the wrapped listener.

Specified by:

getListener in interface ListenerWrapperEventFilter

Returns:

the wrapped listener