org.infinispan.notifications.cachelistener

Class CacheNotifierImpl.ClusteredListenerInvocation<K,V>

java.lang.Object

org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

org.infinispan.notifications.cachelistener.CacheNotifierImpl.ClusteredListenerInvocation<K,V>

All Implemented Interfaces:

CacheEntryListenerInvocation<K,V>, ListenerInvocation<Event<K,V>>

Enclosing class:

CacheNotifierImpl<K,V>

protected static class CacheNotifierImpl.ClusteredListenerInvocation<K,V>
extends CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

This class is to be used with cluster listener invocations only when they have included current state. Thus we can assume all types are CacheEntryEvent, since it doesn't allow other types.

Field Summary

Fields inherited from class org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation

annotation, clustered, converter, filter, filterAndConvert, identifier, invocation, observation, onlyPrimary, sync

Constructor Summary

Constructors

Constructor and Description
ClusteredListenerInvocation(ListenerInvocation<Event<K,V>> invocation, QueueingSegmentListener<K,V,CacheEntryEvent<K,V>> handler, CacheEventFilter<? super K,? super V> filter, CacheEventConverter<? super K,? super V,?> converter, Class<? extends Annotation> annotation, boolean onlyPrimary, UUID identifier, boolean sync, Listener.Observation observation)

Method Summary

Modifier and Type	Method and Description
protected void	doRealInvocation(Event<K,V> event)
void	invoke(Event<K,V> event) Invokes the event

Methods inherited from class org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation

convertValue, getAnnotation, getConverter, getFilter, getIdentifier, getObservation, getTarget, invoke, invokeNoChecks, isClustered, isSync, shouldInvoke, shouldInvoke

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteredListenerInvocation

public ClusteredListenerInvocation(ListenerInvocation<Event<K,V>> invocation,
                                   QueueingSegmentListener<K,V,CacheEntryEvent<K,V>> handler,
                                   CacheEventFilter<? super K,? super V> filter,
                                   CacheEventConverter<? super K,? super V,?> converter,
                                   Class<? extends Annotation> annotation,
                                   boolean onlyPrimary,
                                   UUID identifier,
                                   boolean sync,
                                   Listener.Observation observation)

Method Detail

invoke

public void invoke(Event<K,V> event)

Description copied from interface: ListenerInvocation

Invokes the event

Specified by:

invoke in interface ListenerInvocation<Event<K,V>>

Overrides:

invoke in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

doRealInvocation

protected void doRealInvocation(Event<K,V> event)

Overrides:

doRealInvocation in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>