Package io.micronaut.coherence.event
Class CoherenceEventListenerProcessor
java.lang.Object
io.micronaut.coherence.event.CoherenceEventListenerProcessor
- All Implemented Interfaces:
io.micronaut.context.processor.AnnotationProcessor<CoherenceEventListener,
,io.micronaut.inject.ExecutableMethod<?, ?>> io.micronaut.context.processor.ExecutableMethodProcessor<CoherenceEventListener>
@Singleton
@Context
public class CoherenceEventListenerProcessor
extends Object
implements io.micronaut.context.processor.ExecutableMethodProcessor<CoherenceEventListener>
A
ExecutableMethodProcessor
that processes methods annotated with
@CoherenceEventListener
.- Since:
- 1.0
- Author:
- Jonathan Knight
-
Constructor Summary
ConstructorsConstructorDescriptionCoherenceEventListenerProcessor
(io.micronaut.context.ApplicationContext beanContext, FilterFactories filterFactories, MapEventTransformerFactories transformerFactory) Create theCoherenceEventListenerProcessor
bean. -
Method Summary
Modifier and TypeMethodDescriptionvoid
addMapListener
(io.micronaut.coherence.event.AnnotatedMapListener<?, ?> listener) Add specified listener to the collection of discovered observer-based listeners.List<com.tangosol.net.events.NamedEventInterceptor<?>>
Returns the discovered interceptors.Set<io.micronaut.coherence.event.AnnotatedMapListener<?,
?>> getMapListeners
(String serviceName, String cacheName) Return all map listeners that should be registered for a particular service and cache combination.Collection<io.micronaut.coherence.event.AnnotatedMapListener<?,
?>> Return all map listeners that should be registered against a specific remote cache or map in a specific session.void
process
(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?, ?> method) ProcessExecutableMethod
bean definitions for methods annotated withCoherenceEventListener
.
-
Constructor Details
-
CoherenceEventListenerProcessor
@Inject public CoherenceEventListenerProcessor(io.micronaut.context.ApplicationContext beanContext, FilterFactories filterFactories, MapEventTransformerFactories transformerFactory) Create theCoherenceEventListenerProcessor
bean.- Parameters:
beanContext
- theBeanContext
filterFactories
- the factory to produceFilter
instancestransformerFactory
- the factory to produceMapEventTransformer
instances
-
-
Method Details
-
getInterceptors
Returns the discovered interceptors.- Returns:
- a list of discovered
NamedEventInterceptor
beans
-
process
public void process(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?, ?> method) ProcessExecutableMethod
bean definitions for methods annotated withCoherenceEventListener
. Each method will be turned into either anEventInterceptor
or aMapListener
.- Specified by:
process
in interfaceio.micronaut.context.processor.AnnotationProcessor<CoherenceEventListener,
io.micronaut.inject.ExecutableMethod<?, ?>> - Specified by:
process
in interfaceio.micronaut.context.processor.ExecutableMethodProcessor<CoherenceEventListener>
- Parameters:
beanDefinition
- The bean definition to processmethod
- The executable method
-
addMapListener
public void addMapListener(io.micronaut.coherence.event.AnnotatedMapListener<?, ?> listener) Add specified listener to the collection of discovered observer-based listeners.- Parameters:
listener
- the listener to add
-
getMapListeners
public Set<io.micronaut.coherence.event.AnnotatedMapListener<?,?>> getMapListeners(String serviceName, String cacheName) Return all map listeners that should be registered for a particular service and cache combination.- Parameters:
serviceName
- the name of the servicecacheName
- the name of the cache- Returns:
- a set of all listeners that should be registered
-
getNonWildcardMapListeners
public Collection<io.micronaut.coherence.event.AnnotatedMapListener<?,?>> getNonWildcardMapListeners()Return all map listeners that should be registered against a specific remote cache or map in a specific session.- Returns:
- all map listeners that should be registered against a specific cache or map in a specific session
-