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>
,AutoCloseable
,Aware
,ApplicationContextAware
public class CoherenceTopicListenerSubscribers extends Object implements ApplicationContextAware, com.tangosol.net.Coherence.LifecycleListener, 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, Optional<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") Optional<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 interfaceAutoCloseable
-
createSubscribers
public void createSubscribers(com.tangosol.net.Coherence coherence)
-
setApplicationContext
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
- Specified by:
setApplicationContext
in interfaceApplicationContextAware
- Throws:
BeansException
-
-