Package org.infinispan.notifications.cachelistener

Interface CacheEntryListenerInvocation<K,V>

All Superinterfaces:

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

All Known Implementing Classes:

CacheNotifierImpl.BaseCacheEntryListenerInvocation, CacheNotifierImpl.ClusteredListenerInvocation, DelegatingCacheEntryListenerInvocation

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

Additional listener methods specific to caches.

Since:

7.0

Author:

wburns

Method Summary

Modifier and Type	Method	Description
java.lang.Class<? extends java.lang.annotation.Annotation>	getAnnotation()
<C> CacheEventConverter<? super K,? super V,C>	getConverter()
CacheEventFilter<? super K,? super V>	getFilter()
java.util.Set<java.lang.Class<? extends java.lang.annotation.Annotation>>	getFilterAnnotations()
java.util.UUID	getIdentifier()
DataConversion	getKeyDataConversion()
Listener.Observation	getObservation()
DataConversion	getValueDataConversion()
java.util.concurrent.CompletionStage<java.lang.Void>	invoke(EventWrapper<K,V,CacheEntryEvent<K,V>> event, boolean isLocalNodePrimaryOwner)	Invokes the event
java.util.concurrent.CompletionStage<java.lang.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 Detail

invoke

java.util.concurrent.CompletionStage<java.lang.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

java.util.concurrent.CompletionStage<java.lang.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

java.util.UUID getIdentifier()

getObservation

Listener.Observation getObservation()

getAnnotation

java.lang.Class<? extends java.lang.annotation.Annotation> getAnnotation()

getFilter

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

getConverter

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

getFilterAnnotations

java.util.Set<java.lang.Class<? extends java.lang.annotation.Annotation>> getFilterAnnotations()

getKeyDataConversion

DataConversion getKeyDataConversion()

getValueDataConversion

DataConversion getValueDataConversion()

useStorageFormat

boolean useStorageFormat()

Returns:

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