org.infinispan.notifications.cachelistener

Class CacheNotifierImpl

java.lang.Object

org.infinispan.notifications.AbstractListenerImpl

org.infinispan.notifications.cachelistener.CacheNotifierImpl

All Implemented Interfaces:

CacheNotifier, ClassLoaderAwareFilteringListenable, ClassLoaderAwareListenable, FilteringListenable, Listenable

public final class CacheNotifierImpl
extends AbstractListenerImpl
implements CacheNotifier

Helper class that handles all notifications to registered listeners.

Since:

4.0

Author:

Manik Surtani (manik AT infinispan DOT org), Mircea.Markus@jboss.com

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.notifications.AbstractListenerImpl

AbstractListenerImpl.ListenerInvocation

Field Summary

Fields inherited from class org.infinispan.notifications.AbstractListenerImpl

asyncProcessor, listenersMap, syncProcessor

Constructor Summary

Constructors

Constructor and Description
CacheNotifierImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(Object listener, KeyFilter filter) Adds a listener to the component.
void	addListener(Object listener, KeyFilter filter, ClassLoader classLoader) Adds a listener to the component.
protected Map<Class<? extends Annotation>,Class<?>>	getAllowedMethodAnnotations()
protected Log	getLog()
boolean	isNotificationAllowed(FlagAffectedCommand cmd, List<AbstractListenerImpl.ListenerInvocation> listeners)
void	notifyCacheEntriesEvicted(Collection<InternalCacheEntry> entries, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntriesEvicted event.
void	notifyCacheEntryActivated(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryActivated event.
void	notifyCacheEntryCreated(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryCreated event.
void	notifyCacheEntryEvicted(Object key, Object value, InvocationContext ctx, FlagAffectedCommand command) Syntactic sugar
void	notifyCacheEntryInvalidated(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryInvalidated event.
void	notifyCacheEntryLoaded(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryLoaded event.
void	notifyCacheEntryModified(Object key, Object value, boolean created, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryModified event.
void	notifyCacheEntryPassivated(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryPassivated event.
void	notifyCacheEntryRemoved(Object key, Object value, Object oldValue, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryRemoved event.
void	notifyCacheEntryVisited(Object key, Object value, boolean pre, InvocationContext ctx, FlagAffectedCommand command) Notifies all registered listeners of a CacheEntryVisited event.
void	notifyDataRehashed(ConsistentHash oldCH, ConsistentHash newCH, int newTopologyId, boolean pre)
void	notifyTopologyChanged(ConsistentHash oldConsistentHash, ConsistentHash newConsistentHash, int newTopologyId, boolean pre)
void	notifyTransactionCompleted(GlobalTransaction transaction, boolean successful, InvocationContext ctx) Notifies all registered listeners of a transaction completion event.
void	notifyTransactionRegistered(GlobalTransaction globalTransaction, InvocationContext ctx) Notifies all registered listeners of a transaction registration event.
protected void	resumeIfNeeded(Transaction transaction)
protected Transaction	suspendIfNeeded()

Methods inherited from class org.infinispan.notifications.AbstractListenerImpl

addListener, addListener, getListenerCollectionForAnnotation, getListeners, removeListener, start, testListenerClassValidity, testListenerMethodValidity, validateAndAddListenerInvocation

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.notifications.Listenable

addListener, getListeners, removeListener

Methods inherited from interface org.infinispan.notifications.ClassLoaderAwareListenable

addListener

Constructor Detail

CacheNotifierImpl

public CacheNotifierImpl()

Method Detail

getLog

protected Log getLog()

Specified by:

getLog in class AbstractListenerImpl

getAllowedMethodAnnotations

protected Map<Class<? extends Annotation>,Class<?>> getAllowedMethodAnnotations()

Specified by:

getAllowedMethodAnnotations in class AbstractListenerImpl

suspendIfNeeded

protected final Transaction suspendIfNeeded()

Specified by:

suspendIfNeeded in class AbstractListenerImpl

resumeIfNeeded

protected final void resumeIfNeeded(Transaction transaction)

Specified by:

resumeIfNeeded in class AbstractListenerImpl

notifyCacheEntryCreated

public void notifyCacheEntryCreated(Object key,
                           Object value,
                           boolean pre,
                           InvocationContext ctx,
                           FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryCreated event.

Specified by:

notifyCacheEntryCreated in interface CacheNotifier

notifyCacheEntryModified

public void notifyCacheEntryModified(Object key,
                            Object value,
                            boolean created,
                            boolean pre,
                            InvocationContext ctx,
                            FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryModified event.

Specified by:

notifyCacheEntryModified in interface CacheNotifier

notifyCacheEntryRemoved

public void notifyCacheEntryRemoved(Object key,
                           Object value,
                           Object oldValue,
                           boolean pre,
                           InvocationContext ctx,
                           FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryRemoved event.

Specified by:

notifyCacheEntryRemoved in interface CacheNotifier

notifyCacheEntryVisited

public void notifyCacheEntryVisited(Object key,
                           Object value,
                           boolean pre,
                           InvocationContext ctx,
                           FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryVisited event.

Specified by:

notifyCacheEntryVisited in interface CacheNotifier

notifyCacheEntriesEvicted

public void notifyCacheEntriesEvicted(Collection<InternalCacheEntry> entries,
                             InvocationContext ctx,
                             FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntriesEvicted event.

Specified by:

notifyCacheEntriesEvicted in interface CacheNotifier

notifyCacheEntryEvicted

public void notifyCacheEntryEvicted(Object key,
                           Object value,
                           InvocationContext ctx,
                           FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Syntactic sugar

Specified by:

notifyCacheEntryEvicted in interface CacheNotifier

Parameters:

key - key evicted

value - value evicted

ctx - context

notifyCacheEntryInvalidated

public void notifyCacheEntryInvalidated(Object key,
                               Object value,
                               boolean pre,
                               InvocationContext ctx,
                               FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryInvalidated event.

Specified by:

notifyCacheEntryInvalidated in interface CacheNotifier

notifyCacheEntryLoaded

public void notifyCacheEntryLoaded(Object key,
                          Object value,
                          boolean pre,
                          InvocationContext ctx,
                          FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryLoaded event.

Specified by:

notifyCacheEntryLoaded in interface CacheNotifier

notifyCacheEntryActivated

public void notifyCacheEntryActivated(Object key,
                             Object value,
                             boolean pre,
                             InvocationContext ctx,
                             FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryActivated event.

Specified by:

notifyCacheEntryActivated in interface CacheNotifier

notifyCacheEntryPassivated

public void notifyCacheEntryPassivated(Object key,
                              Object value,
                              boolean pre,
                              InvocationContext ctx,
                              FlagAffectedCommand command)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a CacheEntryPassivated event.

Specified by:

notifyCacheEntryPassivated in interface CacheNotifier

notifyTransactionCompleted

public void notifyTransactionCompleted(GlobalTransaction transaction,
                              boolean successful,
                              InvocationContext ctx)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a transaction completion event.

Specified by:

notifyTransactionCompleted in interface CacheNotifier

Parameters:

transaction - the transaction that has just completed

successful - if true, the transaction committed. If false, this is a rollback event

notifyTransactionRegistered

public void notifyTransactionRegistered(GlobalTransaction globalTransaction,
                               InvocationContext ctx)

Description copied from interface: CacheNotifier

Notifies all registered listeners of a transaction registration event.

Specified by:

notifyTransactionRegistered in interface CacheNotifier

notifyDataRehashed

public void notifyDataRehashed(ConsistentHash oldCH,
                      ConsistentHash newCH,
                      int newTopologyId,
                      boolean pre)

Specified by:

notifyDataRehashed in interface CacheNotifier

notifyTopologyChanged

public void notifyTopologyChanged(ConsistentHash oldConsistentHash,
                         ConsistentHash newConsistentHash,
                         int newTopologyId,
                         boolean pre)

Specified by:

notifyTopologyChanged in interface CacheNotifier

isNotificationAllowed

public boolean isNotificationAllowed(FlagAffectedCommand cmd,
                            List<AbstractListenerImpl.ListenerInvocation> listeners)

addListener

public void addListener(Object listener,
               KeyFilter filter,
               ClassLoader classLoader)

Description copied from interface: ClassLoaderAwareFilteringListenable

Adds a listener to the component. Typically, listeners would need to be annotated with Listener and further to that, contain methods annotated appropriately, otherwise the listener will not be registered.

See the Listener annotation for more information.

Specified by:

addListener in interface ClassLoaderAwareFilteringListenable

Parameters:

listener - must not be null.

classLoader - class loader

addListener

public void addListener(Object listener,
               KeyFilter filter)

Description copied from interface: FilteringListenable

Adds a listener to the component. Typically, listeners would need to be annotated with Listener and further to that, contain methods annotated appropriately, otherwise the listener will not be registered.

See the Listener annotation for more information.

Specified by:

addListener in interface FilteringListenable

Parameters:

listener - must not be null.