protected static class CacheNotifierImpl.BaseCacheEntryListenerInvocation<K,V> extends Object implements CacheEntryListenerInvocation<K,V>
Modifier and Type | Field and Description |
---|---|
protected Class<? extends Annotation> |
annotation |
protected boolean |
clustered |
protected CacheEventConverter<? super K,? super V,?> |
converter |
protected CacheEventFilter<? super K,? super V> |
filter |
protected boolean |
filterAndConvert |
protected UUID |
identifier |
protected ListenerInvocation<Event<K,V>> |
invocation |
protected Listener.Observation |
observation |
protected boolean |
onlyPrimary |
protected boolean |
sync |
Modifier | Constructor and Description |
---|---|
protected |
BaseCacheEntryListenerInvocation(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) |
Modifier and Type | Method and Description |
---|---|
protected CacheEntryEvent<K,V> |
convertValue(CacheEventConverter<? super K,? super V,?> converter,
CacheEntryEvent<K,V> event) |
protected void |
doRealInvocation(Event<K,V> event) |
Class<? extends Annotation> |
getAnnotation() |
CacheEventConverter<? super K,? super V,?> |
getConverter() |
CacheEventFilter<? super K,? super V> |
getFilter() |
UUID |
getIdentifier() |
Listener.Observation |
getObservation() |
Object |
getTarget()
The listener instance that is notified of events
|
void |
invoke(CacheEntryEvent<K,V> event,
boolean isLocalNodePrimaryOwner)
This is the entry point for local listeners firing events
|
void |
invoke(Event<K,V> event)
Invokes the event
|
void |
invokeNoChecks(CacheEntryEvent<K,V> event,
boolean skipQueue,
boolean skipConverter)
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) |
protected final ListenerInvocation<Event<K,V>> invocation
protected final CacheEventFilter<? super K,? super V> filter
protected final CacheEventConverter<? super K,? super V,?> converter
protected final boolean onlyPrimary
protected final boolean clustered
protected final UUID identifier
protected final Class<? extends Annotation> annotation
protected final boolean sync
protected final boolean filterAndConvert
protected final Listener.Observation observation
protected BaseCacheEntryListenerInvocation(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)
public void invoke(Event<K,V> event)
ListenerInvocation
invoke
in interface ListenerInvocation<Event<K,V>>
public void invoke(CacheEntryEvent<K,V> event, boolean isLocalNodePrimaryOwner)
invoke
in interface CacheEntryListenerInvocation<K,V>
event
- isLocalNodePrimaryOwner
- public void invokeNoChecks(CacheEntryEvent<K,V> event, boolean skipQueue, boolean skipConverter)
invokeNoChecks
in interface CacheEntryListenerInvocation<K,V>
event
- skipQueue
- protected CacheEntryEvent<K,V> shouldInvoke(CacheEntryEvent<K,V> event, boolean isLocalNodePrimaryOwner)
public Object getTarget()
ListenerInvocation
getTarget
in interface ListenerInvocation<Event<K,V>>
public CacheEventFilter<? super K,? super V> getFilter()
getFilter
in interface CacheEntryListenerInvocation<K,V>
public CacheEventConverter<? super K,? super V,?> getConverter()
getConverter
in interface CacheEntryListenerInvocation<K,V>
public boolean isClustered()
isClustered
in interface CacheEntryListenerInvocation<K,V>
public UUID getIdentifier()
getIdentifier
in interface CacheEntryListenerInvocation<K,V>
public Listener.Observation getObservation()
getObservation
in interface CacheEntryListenerInvocation<K,V>
public Class<? extends Annotation> getAnnotation()
getAnnotation
in interface CacheEntryListenerInvocation<K,V>
protected CacheEntryEvent<K,V> convertValue(CacheEventConverter<? super K,? super V,?> converter, CacheEntryEvent<K,V> event)
public boolean isSync()
isSync
in interface CacheEntryListenerInvocation<K,V>
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.