Class AbstractHazelcastMessageProducer

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.hazelcast.inbound.AbstractHazelcastMessageProducer
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.core.MessageProducer, org.springframework.integration.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ManageableLifecycle, org.springframework.integration.support.management.ManageableSmartLifecycle, org.springframework.integration.support.management.TrackableComponent
Direct Known Subclasses:
HazelcastContinuousQueryMessageProducer, HazelcastEventDrivenMessageProducer

public abstract class AbstractHazelcastMessageProducer extends org.springframework.integration.endpoint.MessageProducerSupport
Hazelcast Base Event-Driven Message Producer.
Since:
6.0
  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected class 
    A base event listener abstraction.
    protected final class 
    The AbstractHazelcastMessageProducer.AbstractHazelcastEventListener implementation for the AbstractIMapEvents.
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final com.hazelcast.core.DistributedObject
     

    Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    lifecycleCondition, lifecycleLock

    Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

    EXPRESSION_PARSER, logger

    Fields inherited from interface org.springframework.context.SmartLifecycle

    DEFAULT_PHASE
  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractHazelcastMessageProducer(com.hazelcast.core.DistributedObject distributedObject)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    protected Set<String>
     
     
    protected UUID
     
    void
    setCacheEventTypes(String cacheEventTypes)
     
    void
     
    protected void
    setHazelcastRegisteredEventListenerId(UUID hazelcastRegisteredEventListenerId)
     

    Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

    afterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

    Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

    Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

    afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.springframework.integration.support.context.NamedComponent

    getBeanName, getComponentName, getComponentType
  • 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)