org.infinispan.notifications

Class AbstractListenerImpl

java.lang.Object

org.infinispan.notifications.AbstractListenerImpl

Direct Known Subclasses:

CacheManagerNotifierImpl, CacheNotifierImpl

public abstract class AbstractListenerImpl
extends Object

Functionality common to both CacheManagerNotifierImpl and CacheNotifierImpl

Author:

Manik Surtani

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractListenerImpl.ListenerInvocation Class that encapsulates a valid invocation for a given registered listener - containing a reference to the method to be invoked as well as the target object.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	asyncProcessor
protected Map<Class<? extends Annotation>,List<AbstractListenerImpl.ListenerInvocation>>	listenersMap
protected ExecutorService	syncProcessor

Constructor Summary

Constructors

Constructor and Description
AbstractListenerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(Object listener)
void	addListener(Object listener, ClassLoader classLoader)
protected abstract Map<Class<? extends Annotation>,Class<?>>	getAllowedMethodAnnotations()
protected List<AbstractListenerImpl.ListenerInvocation>	getListenerCollectionForAnnotation(Class<? extends Annotation> annotation)
Set<Object>	getListeners()
protected abstract Log	getLog()
void	removeListener(Object listener)
protected abstract void	resumeIfNeeded(Transaction transaction)
void	start()
protected abstract Transaction	suspendIfNeeded()
protected static Listener	testListenerClassValidity(Class<?> listenerClass) Tests if a class is properly annotated as a CacheListener and returns the Listener annotation.
protected static void	testListenerMethodValidity(Method m, Class<?> allowedParameter, String annotationName)
protected void	validateAndAddListenerInvocation(Object listener, KeyFilter filter, ClassLoader classLoader) Loops through all valid methods on the object passed in, and caches the relevant methods as AbstractListenerImpl.ListenerInvocation for invocation by reflection.

Methods inherited from class java.lang.Object

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

Field Detail

listenersMap

protected final Map<Class<? extends Annotation>,List<AbstractListenerImpl.ListenerInvocation>> listenersMap

syncProcessor

protected ExecutorService syncProcessor

asyncProcessor

protected ExecutorService asyncProcessor

Constructor Detail

AbstractListenerImpl

public AbstractListenerImpl()

Method Detail

start

public void start()

getLog

protected abstract Log getLog()

getAllowedMethodAnnotations

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

getListenerCollectionForAnnotation

protected List<AbstractListenerImpl.ListenerInvocation> getListenerCollectionForAnnotation(Class<? extends Annotation> annotation)

removeListener

public void removeListener(Object listener)

addListener

public void addListener(Object listener)

addListener

public void addListener(Object listener,
               ClassLoader classLoader)

getListeners

public Set<Object> getListeners()

validateAndAddListenerInvocation

protected void validateAndAddListenerInvocation(Object listener,
                                    KeyFilter filter,
                                    ClassLoader classLoader)

Loops through all valid methods on the object passed in, and caches the relevant methods as AbstractListenerImpl.ListenerInvocation for invocation by reflection.

Parameters:

listener - object to be considered as a listener.

testListenerClassValidity

protected static Listener testListenerClassValidity(Class<?> listenerClass)

Tests if a class is properly annotated as a CacheListener and returns the Listener annotation.

Parameters:

listenerClass - class to inspect

Returns:

the Listener annotation

testListenerMethodValidity

protected static void testListenerMethodValidity(Method m,
                              Class<?> allowedParameter,
                              String annotationName)

suspendIfNeeded

protected abstract Transaction suspendIfNeeded()

resumeIfNeeded

protected abstract void resumeIfNeeded(Transaction transaction)