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
ConstructorDescriptionCoherenceTopicListenerSubscribers
(FilterService filterService, ExtractorService extractorService, CoherenceTopicListenerCandidates candidates, Optional<ExecutorService> executorService) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
createSubscribers
(com.tangosol.net.Coherence coherence) boolean
void
onEvent
(com.tangosol.net.events.CoherenceLifecycleEvent event) void
setApplicationContext
(ApplicationContext applicationContext) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.tangosol.net.Coherence.LifecycleListener
introduceEventDispatcher
-
Constructor Details
-
CoherenceTopicListenerSubscribers
public CoherenceTopicListenerSubscribers(FilterService filterService, ExtractorService extractorService, CoherenceTopicListenerCandidates candidates, @Named("consumers") Optional<ExecutorService> executorService)
-
-
Method Details
-
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
- Specified by:
close
in interfaceAutoCloseable
-
createSubscribers
public void createSubscribers(com.tangosol.net.Coherence coherence) -
setApplicationContext
- Specified by:
setApplicationContext
in interfaceApplicationContextAware
- Throws:
BeansException
-