Package 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>, org.infinispan.notifications.impl.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

Description

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

Method Summary

Modifier and Type	Method	Description
protected java.util.concurrent.CompletionStage<java.lang.Void>	doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped)
java.util.concurrent.CompletionStage<java.lang.Void>	invoke(Event<K,V> event)	Invokes the event

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, toString, wait, wait, wait

Constructor Detail

ClusteredListenerInvocation

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

Method Detail

invoke

public java.util.concurrent.CompletionStage<java.lang.Void> invoke(Event<K,V> event)

Description copied from interface: org.infinispan.notifications.impl.ListenerInvocation

Invokes the event

Specified by:

invoke in interface org.infinispan.notifications.impl.ListenerInvocation<K>

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 java.util.concurrent.CompletionStage<java.lang.Void> doRealInvocation(EventWrapper<K,V,CacheEntryEvent<K,V>> wrapped)

Overrides:

doRealInvocation in class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V>