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>, 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(CacheEntryEvent, 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 and Description
protected CacheEntryListenerInvocation<K,V>	invocation

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DelegatingCacheEntryListenerInvocation(CacheEntryListenerInvocation<K,V> invocation)

Method Summary

Modifier and Type	Method and 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()
Listener.Observation	getObservation()
Object	getTarget() The listener instance that is notified of events
void	invoke(CacheEntryEvent<K,V> event, boolean isLocalNodePrimaryOwner)
void	invoke(Event<K,V> event) Invokes the event
void	invokeNoChecks(CacheEntryEvent<K,V> event, boolean skipQueue, boolean skipConverter)
boolean	isClustered()
boolean	isSync()
abstract void	unregister() Stops handling the invocation.

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: ListenerInvocation

The listener instance that is notified of events

Specified by:

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

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

invoke

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

Specified by:

invoke in interface CacheEntryListenerInvocation<K,V>

invokeNoChecks

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

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>