Class AbstractHazelcastMessageProducer

All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
Direct Known Subclasses:
HazelcastContinuousQueryMessageProducer, HazelcastEventDrivenMessageProducer

public abstract class AbstractHazelcastMessageProducer extends MessageProducerSupport
Hazelcast Base Event-Driven Message Producer.
Since:
6.0
Author:
Eren Avsarogullari, Artem Bilan
  • Field Details

    • distributedObject

      protected final com.hazelcast.core.DistributedObject distributedObject
  • Constructor Details

    • AbstractHazelcastMessageProducer

      public AbstractHazelcastMessageProducer(com.hazelcast.core.DistributedObject distributedObject)
  • Method Details

    • getCacheEvents

      protected Set<String> getCacheEvents()
    • setCacheEventTypes

      public void setCacheEventTypes(String cacheEventTypes)
    • getCacheListeningPolicy

      protected CacheListeningPolicyType getCacheListeningPolicy()
    • setCacheListeningPolicy

      public void setCacheListeningPolicy(CacheListeningPolicyType cacheListeningPolicy)
    • getHazelcastRegisteredEventListenerId

      protected UUID getHazelcastRegisteredEventListenerId()
    • setHazelcastRegisteredEventListenerId

      protected void setHazelcastRegisteredEventListenerId(UUID hazelcastRegisteredEventListenerId)