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:

CacheEntryListenerInvocation<K,V>, org.infinispan.notifications.impl.ListenerInvocation<Event<K,V>>

public abstract class DelegatingCacheEntryListenerInvocation<K,V>
extends Object
implements 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 CacheEntryListenerInvocation<K,V>	invocation

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DelegatingCacheEntryListenerInvocation(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()
DataConversion	getKeyDataConversion()
Listener.Observation	getObservation()
Object	getTarget()	The listener instance that is notified of events
DataConversion	getValueDataConversion()
void	invoke(Event<K,V> event)	Invokes the event
void	invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean isLocalNodePrimaryOwner)
void	invokeNoChecks(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()

Methods inherited from class java.lang.Object

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

Field Detail

invocation

protected final CacheEntryListenerInvocation<K,V> invocation

Constructor Detail

DelegatingCacheEntryListenerInvocation

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

Description copied from interface: org.infinispan.notifications.impl.ListenerInvocation

The listener instance that is notified of events

Specified by:

getTarget in interface org.infinispan.notifications.impl.ListenerInvocation<K>

invoke

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

Description copied from interface: org.infinispan.notifications.impl.ListenerInvocation

Invokes the event

Specified by:

invoke in interface org.infinispan.notifications.impl.ListenerInvocation<K>

invoke

public void invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> event,
                   boolean isLocalNodePrimaryOwner)

Specified by:

invoke in interface CacheEntryListenerInvocation<K,V>

invokeNoChecks

public void invokeNoChecks(EventWrapper<K,V,CacheEntryEvent<K,V>> event,
                           boolean skipQueue,
                           boolean skipConverter,
                           boolean needsTransform)

Specified by:

invokeNoChecks in interface CacheEntryListenerInvocation<K,V>

isClustered

public boolean isClustered()

Specified by:

isClustered in interface CacheEntryListenerInvocation<K,V>

isSync

public boolean isSync()

Specified by:

isSync in interface CacheEntryListenerInvocation<K,V>

getIdentifier

public UUID getIdentifier()

Specified by:

getIdentifier in interface CacheEntryListenerInvocation<K,V>

getObservation

public Listener.Observation getObservation()

Specified by:

getObservation in interface CacheEntryListenerInvocation<K,V>

getAnnotation

public Class<? extends Annotation> getAnnotation()

Specified by:

getAnnotation in interface CacheEntryListenerInvocation<K,V>

getFilter

public CacheEventFilter<? super K,? super V> getFilter()

Specified by:

getFilter in interface CacheEntryListenerInvocation<K,V>

getConverter

public <C> CacheEventConverter<? super K,? super V,C> getConverter()

Specified by:

getConverter in interface CacheEntryListenerInvocation<K,V>

getFilterAnnotations

public Set<Class<? extends Annotation>> getFilterAnnotations()

Specified by:

getFilterAnnotations in interface CacheEntryListenerInvocation<K,V>

getKeyDataConversion

public DataConversion getKeyDataConversion()

Specified by:

getKeyDataConversion in interface CacheEntryListenerInvocation<K,V>

getValueDataConversion

public DataConversion getValueDataConversion()

Specified by:

getValueDataConversion in interface CacheEntryListenerInvocation<K,V>

useStorageFormat

public boolean useStorageFormat()

Specified by:

useStorageFormat in interface CacheEntryListenerInvocation<K,V>

Returns:

true if the filter/converter should be done in the storage format