Class CoherenceTopicListenerSubscribers
- java.lang.Object
-
- com.oracle.coherence.spring.messaging.CoherenceTopicListenerSubscribers
-
- All Implemented Interfaces:
com.tangosol.net.Coherence.LifecycleListener
,com.tangosol.net.events.EventDispatcherAwareInterceptor<com.tangosol.net.events.CoherenceLifecycleEvent>
,com.tangosol.net.events.EventInterceptor<com.tangosol.net.events.CoherenceLifecycleEvent>
,java.lang.AutoCloseable
,Aware
,ApplicationContextAware
public class CoherenceTopicListenerSubscribers extends java.lang.Object implements ApplicationContextAware, com.tangosol.net.Coherence.LifecycleListener, java.lang.AutoCloseable
A bean for creating subscribers related to @CoherenceTopicListener
.- Since:
- 3.0
- Author:
- Vaso Putica
-
-
Constructor Summary
Constructors Constructor Description CoherenceTopicListenerSubscribers(FilterService filterService, ExtractorService extractorService, CoherenceTopicListenerCandidates candidates, java.util.Optional<java.util.concurrent.ExecutorService> executorService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
createSubscribers(com.tangosol.net.Coherence coherence)
boolean
isSubscribed()
void
onEvent(com.tangosol.net.events.CoherenceLifecycleEvent event)
void
setApplicationContext(ApplicationContext applicationContext)
-
-
-
Constructor Detail
-
CoherenceTopicListenerSubscribers
public CoherenceTopicListenerSubscribers(FilterService filterService, ExtractorService extractorService, CoherenceTopicListenerCandidates candidates, @Named("consumers") java.util.Optional<java.util.concurrent.ExecutorService> executorService)
-
-
Method Detail
-
isSubscribed
public boolean isSubscribed()
-
onEvent
public void onEvent(com.tangosol.net.events.CoherenceLifecycleEvent event)
- Specified by:
onEvent
in interfacecom.tangosol.net.Coherence.LifecycleListener
- Specified by:
onEvent
in interfacecom.tangosol.net.events.EventInterceptor<com.tangosol.net.events.CoherenceLifecycleEvent>
-
close
@PreDestroy public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
-
createSubscribers
public void createSubscribers(com.tangosol.net.Coherence coherence)
-
setApplicationContext
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
- Specified by:
setApplicationContext
in interfaceApplicationContextAware
- Throws:
BeansException
-
-