Class DelegatingCacheEntryListenerInvocation<K,V>
- java.lang.Object
-
- org.infinispan.notifications.cachelistener.filter.DelegatingCacheEntryListenerInvocation<K,V>
-
- Type Parameters:
K- cache key typeV- cache value type
- All Implemented Interfaces:
org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V>,org.infinispan.notifications.impl.ListenerInvocation<Event<K,V>>
public abstract class DelegatingCacheEntryListenerInvocation<K,V> extends Object implements org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V>
A wrapper around aCacheEntryListenerInvocationthat keeps a reference to theFilterIndexingServiceProviderinstance that handles this invocation. All methods are delegated to the wrapped invocation exceptCacheEntryListenerInvocation.invoke(EventWrapper, boolean)andListenerInvocation.invoke(Object). FilterIndexingServiceProvider implementors must extends this class and implement its abstractunregister()method.- Since:
- 7.2
- Author:
- anistor@redhat.com
-
-
Field Summary
Fields Modifier and Type Field Description protected org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V>invocation
-
Constructor Summary
Constructors Modifier Constructor Description protectedDelegatingCacheEntryListenerInvocation(org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V> invocation)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description Class<? extends Annotation>getAnnotation()<C> CacheEventConverter<? super K,? super V,C>getConverter()CacheEventFilter<? super K,? super V>getFilter()Set<Class<? extends Annotation>>getFilterAnnotations()UUIDgetIdentifier()org.infinispan.encoding.DataConversiongetKeyDataConversion()Listener.ObservationgetObservation()ObjectgetTarget()org.infinispan.encoding.DataConversiongetValueDataConversion()CompletionStage<Void>invoke(Event<K,V> event)CompletionStage<Void>invoke(org.infinispan.notifications.cachelistener.EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean isLocalNodePrimaryOwner)CompletionStage<Void>invokeNoChecks(org.infinispan.notifications.cachelistener.EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean skipQueue, boolean skipConverter, boolean needsTransform)booleanisClustered()booleanisSync()abstract voidunregister()Stops handling the invocation.booleanuseStorageFormat()
-
-
-
Method Detail
-
unregister
public abstract void unregister()
Stops handling the invocation. This is called when the listener is being unregistered.
-
getTarget
public Object getTarget()
-
invoke
public CompletionStage<Void> invoke(Event<K,V> event)
-
invoke
public CompletionStage<Void> invoke(org.infinispan.notifications.cachelistener.EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean isLocalNodePrimaryOwner)
-
invokeNoChecks
public CompletionStage<Void> invokeNoChecks(org.infinispan.notifications.cachelistener.EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean skipQueue, boolean skipConverter, boolean needsTransform)
-
isClustered
public boolean isClustered()
-
isSync
public boolean isSync()
-
getIdentifier
public UUID getIdentifier()
-
getObservation
public Listener.Observation getObservation()
-
getAnnotation
public Class<? extends Annotation> getAnnotation()
-
getFilter
public CacheEventFilter<? super K,? super V> getFilter()
-
getConverter
public <C> CacheEventConverter<? super K,? super V,C> getConverter()
-
getFilterAnnotations
public Set<Class<? extends Annotation>> getFilterAnnotations()
-
getKeyDataConversion
public org.infinispan.encoding.DataConversion getKeyDataConversion()
-
getValueDataConversion
public org.infinispan.encoding.DataConversion getValueDataConversion()
-
useStorageFormat
public boolean useStorageFormat()
-
-