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>
,org.infinispan.notifications.impl.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, filterAnnotations, identifier, invocation, observation, onlyPrimary, sync
-
-
Constructor Summary
Constructors Constructor Description ClusteredListenerInvocation(org.infinispan.notifications.impl.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, Set<Class<? extends Annotation>> filterAnnotations, DataConversion keyDataConversion, DataConversion valueDataConversion, boolean useStorageFormat)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped)
void
invoke(Event<K,V> event)
Invokes the event-
Methods inherited from class org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation
convertValue, doRealInvocation, getAnnotation, getConverter, getFilter, getFilterAnnotations, getIdentifier, getKeyDataConversion, getObservation, getTarget, getValueDataConversion, invoke, invokeNoChecks, isClustered, isSync, shouldInvoke, shouldInvoke, useStorageFormat
-
-
-
-
Constructor Detail
-
ClusteredListenerInvocation
public ClusteredListenerInvocation(org.infinispan.notifications.impl.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, Set<Class<? extends Annotation>> filterAnnotations, DataConversion keyDataConversion, DataConversion valueDataConversion, boolean useStorageFormat)
-
-
Method Detail
-
invoke
public void invoke(Event<K,V> event)
Description copied from interface:org.infinispan.notifications.impl.ListenerInvocation
Invokes the event- Specified by:
invoke
in interfaceorg.infinispan.notifications.impl.ListenerInvocation<K>
- Overrides:
invoke
in classCacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>
-
doRealInvocation
protected void doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped)
- Overrides:
doRealInvocation
in classCacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>
-
-