Package org.infinispan.notifications.cachelistener.filter

Class DelegatingCacheEntryListenerInvocation<K,V>

java.lang.Object

org.infinispan.notifications.cachelistener.filter.DelegatingCacheEntryListenerInvocation<K,V>

Type Parameters:

K - cache key type

V - 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 a CacheEntryListenerInvocation that keeps a reference to the FilterIndexingServiceProvider instance that handles this invocation. All methods are delegated to the wrapped invocation except CacheEntryListenerInvocation.invoke(EventWrapper, boolean) and ListenerInvocation.invoke(Object). FilterIndexingServiceProvider implementors must extends this class and implement its abstract unregister() 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
protected	DelegatingCacheEntryListenerInvocation(org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V> invocation)

Method Summary

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()
UUID	getIdentifier()
org.infinispan.encoding.DataConversion	getKeyDataConversion()
Listener.Observation	getObservation()
Object	getTarget()
org.infinispan.encoding.DataConversion	getValueDataConversion()
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)
boolean	isClustered()
boolean	isSync()
abstract void	unregister()	Stops handling the invocation.
boolean	useStorageFormat()

Field Detail

invocation

protected final org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V> invocation

Constructor Detail

DelegatingCacheEntryListenerInvocation

protected DelegatingCacheEntryListenerInvocation(org.infinispan.notifications.cachelistener.CacheEntryListenerInvocation<K,V> invocation)

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()