org.infinispan.notifications.cachelistener

Class CacheNotifierImpl.ClusteredListenerInvocation<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

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

Enclosing class:

CacheNotifierImpl<K,V>

protected static class CacheNotifierImpl.ClusteredListenerInvocation<K,V>
extends CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

This class is to be used with cluster listener invocations only when they have included current state. Thus we can assume all types are CacheEntryEvent, since it doesn't allow other types.

Field Summary

Fields inherited from class org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation

annotation, clustered, converter, filter, filterAndConvert, filterAnnotations, identifier, invocation, observation, onlyPrimary, sync

Constructor Summary

Constructors

Constructor and Description

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

Method Summary

Modifier and Type	Method and Description
protected CompletionStage<Void>	doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped)
CompletionStage<Void>	invoke(Event<K,V> event) Invokes the event
String	toString()

Methods inherited from class org.infinispan.notifications.cachelistener.CacheNotifierImpl.BaseCacheEntryListenerInvocation

convertValue, doRealInvocation, getAnnotation, getConverter, getFilter, getFilterAnnotations, getIdentifier, getKeyDataConversion, getObservation, getTarget, getValueDataConversion, invoke, invokeNoChecks, isClustered, isSync, shouldInvoke, shouldInvoke, useStorageFormat

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteredListenerInvocation

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

Method Detail

invoke

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

Description copied from interface: ListenerInvocation

Invokes the event

Specified by:

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

Overrides:

invoke in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

Returns:

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

doRealInvocation

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

Overrides:

doRealInvocation in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>

toString

public String toString()

Overrides:

toString in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>