Package org.infinispan.notifications.cachelistener

Interface CacheEntryListenerInvocation<K,V>

All Superinterfaces:

ListenerInvocation<Event<K,V>>

All Known Implementing Classes:

CacheNotifierImpl.BaseCacheEntryListenerInvocation, CacheNotifierImpl.ClusteredListenerInvocation, DelegatingCacheEntryListenerInvocation

public interface CacheEntryListenerInvocation<K,V>
extends ListenerInvocation<Event<K,V>>

Additional listener methods specific to caches.

Since:

7.0

Author:

wburns

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()
DataConversion	getValueDataConversion()
CompletionStage<Void>	invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean isLocalNodePrimaryOwner)	Invokes the event
CompletionStage<Void>	invokeNoChecks(EventWrapper<K,V,CacheEntryEvent<K,V>> wrappedEvent, boolean skipQueue, boolean skipConverter, boolean needsTransform)	Invokes the event without applying filters or converters
boolean	isClustered()
boolean	isSync()
boolean	useStorageFormat()

Methods inherited from interface org.infinispan.notifications.impl.ListenerInvocation

getTarget, invoke

Method Details

invoke

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

Invokes the event

Parameters:

event -

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

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

Invokes the event without applying filters or converters

Parameters:

wrappedEvent -

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

isClustered

boolean isClustered()

isSync

boolean isSync()

getIdentifier

UUID getIdentifier()

getObservation

Listener.Observation getObservation()

getAnnotation

Class<? extends Annotation> getAnnotation()

getFilter

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

getConverter

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

getFilterAnnotations

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

getKeyDataConversion

DataConversion getKeyDataConversion()

getValueDataConversion

DataConversion getValueDataConversion()

useStorageFormat

boolean useStorageFormat()

Returns:

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