Package org.infinispan.notifications.cachelistener

Class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

java.lang.Object

org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

All Implemented Interfaces:

CacheEntryListenerInvocation<K,V>, ListenerInvocation<Event<K,V>>

Direct Known Subclasses:

CacheNotifierImpl.ClusteredListenerInvocation

Enclosing class:

CacheNotifierImpl<K,V>

protected static class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>
extends Object
implements CacheEntryListenerInvocation<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
protected final Class<? extends Annotation>	annotation
protected final boolean	clustered
protected final CacheEventConverter<? super K,? super V,?>	converter
protected final CacheEventFilter<? super K,? super V>	filter
protected final boolean	filterAndConvert
protected final Set<Class<? extends Annotation>>	filterAnnotations
protected final UUID	identifier
protected final ListenerInvocation<Event<K,V>>	invocation
protected final Listener.Observation	observation
protected final boolean	onlyPrimary
protected final boolean	sync

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseCacheEntryListenerInvocation(EncoderRegistry encoderRegistry, ListenerInvocation<Event<K,V>> invocation, CacheEventFilter<? super K,? super V> filter, CacheEventConverter<? super K,? super V,?> converter, Class<? extends Annotation> annotation, boolean onlyPrimary, boolean clustered, UUID identifier, boolean sync, Listener.Observation observation, Set<Class<? extends Annotation>> filterAnnotations, DataConversion keyDataConversion, DataConversion valueDataConversion, boolean useStorageFormat)

Method Summary

Modifier and Type	Method	Description
protected CacheEntryEvent<K,V>	convertValue(CacheEventConverter<? super K,? super V,?> converter, CacheEntryEvent<K,V> event)
protected CompletionStage<Void>	doRealInvocation(Event<K,V> event)
protected CompletionStage<Void>	doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> event)
Class<? extends Annotation>	getAnnotation()
CacheEventConverter<? super K,? super V,?>	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()
CompletionStage<Void>	invoke(Event<K,V> event)	Invokes the event
CompletionStage<Void>	invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped, boolean isLocalNodePrimaryOwner)	This is the entry point for local listeners firing events
CompletionStage<Void>	invokeNoChecks(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped, boolean skipQueue, boolean skipConverter, boolean needsTransform)	This is the entry point for remote listener events being fired
boolean	isClustered()
boolean	isSync()
protected CacheEntryEvent<K,V>	shouldInvoke(CacheEntryEvent<K,V> event, boolean isLocalNodePrimaryOwner)
protected boolean	shouldInvoke(Event<K,V> event)
String	toString()
boolean	useStorageFormat()

Methods inherited from class java.lang.Object

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

Field Details

invocation

protected final ListenerInvocation<Event<K,V>> invocation

filter

protected final CacheEventFilter<? super K,? super V> filter

converter

protected final CacheEventConverter<? super K,? super V,?> converter

onlyPrimary

protected final boolean onlyPrimary

clustered

protected final boolean clustered

identifier

protected final UUID identifier

annotation

protected final Class<? extends Annotation> annotation

sync

protected final boolean sync

filterAndConvert

protected final boolean filterAndConvert

observation

protected final Listener.Observation observation

filterAnnotations

protected final Set<Class<? extends Annotation>> filterAnnotations

Constructor Details

BaseCacheEntryListenerInvocation

protected BaseCacheEntryListenerInvocation(EncoderRegistry encoderRegistry,
 ListenerInvocation<Event<K,V>> invocation,
 CacheEventFilter<? super K,? super V> filter,
 CacheEventConverter<? super K,? super V,?> converter,
 Class<? extends Annotation> annotation,
 boolean onlyPrimary,
 boolean clustered,
 UUID identifier,
 boolean sync,
 Listener.Observation observation,
 Set<Class<? extends Annotation>> filterAnnotations,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion,
 boolean useStorageFormat)

Method Details

invoke

public CompletionStage<Void> invoke(Event<K,V> event)

Description copied from interface: ListenerInvocation

Invokes the event

Specified by:

invoke in interface ListenerInvocation<K>

Parameters:

event -

Returns:

null if event was ignored or already complete otherwise the event will be completely notified when the provided stage is completed

invoke

public CompletionStage<Void> invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped,
 boolean isLocalNodePrimaryOwner)

This is the entry point for local listeners firing events

Specified by:

invoke in interface CacheEntryListenerInvocation<K,V>

Parameters:

wrapped -

isLocalNodePrimaryOwner -

Returns:

null if event was ignored or already complete otherwise all listeners for the event will be notified when the provided stage is completed

invokeNoChecks

public CompletionStage<Void> invokeNoChecks(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped,
 boolean skipQueue,
 boolean skipConverter,
 boolean needsTransform)

This is the entry point for remote listener events being fired

Specified by:

invokeNoChecks in interface CacheEntryListenerInvocation<K,V>

Parameters:

wrapped -

skipQueue -

skipConverter -

needsTransform -

Returns:

null if event was ignored or already complete otherwise all listeners for the event will be notified when the provided stage is completed

doRealInvocation

protected CompletionStage<Void> doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> event)

doRealInvocation

protected CompletionStage<Void> doRealInvocation(Event<K,V> event)

shouldInvoke

protected boolean shouldInvoke(Event<K,V> event)

shouldInvoke

protected CacheEntryEvent<K,V> shouldInvoke(CacheEntryEvent<K,V> event,
 boolean isLocalNodePrimaryOwner)

getTarget

public Object getTarget()

Description copied from interface: ListenerInvocation

The listener instance that is notified of events

Specified by:

getTarget in interface ListenerInvocation<K>

getFilter

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

Specified by:

getFilter 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

getConverter

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

Specified by:

getConverter in interface CacheEntryListenerInvocation<K,V>

isClustered

public boolean isClustered()

Specified by:

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

convertValue

protected CacheEntryEvent<K,V> convertValue(CacheEventConverter<? super K,? super V,?> converter,
 CacheEntryEvent<K,V> event)

isSync

public boolean isSync()

Specified by:

isSync in interface CacheEntryListenerInvocation<K,V>

toString

public String toString()

Overrides:

toString in class Object