Package com.oracle.coherence.spring.messaging

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

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)

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 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 interface com.tangosol.net.Coherence.LifecycleListener

Specified by:

onEvent in interface com.tangosol.net.events.EventInterceptor<com.tangosol.net.events.CoherenceLifecycleEvent>

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

createSubscribers

public void createSubscribers(com.tangosol.net.Coherence coherence)

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException