public abstract class AbstractHazelcastMessageProducer
extends org.springframework.integration.endpoint.MessageProducerSupport
| Modifier and Type | Class and Description |
|---|---|
protected class |
AbstractHazelcastMessageProducer.AbstractHazelcastEventListener<E>
A base event listener abstraction.
|
protected class |
AbstractHazelcastMessageProducer.HazelcastEntryListener<K,V>
The
AbstractHazelcastMessageProducer.AbstractHazelcastEventListener implementation for the AbstractIMapEvents. |
| Modifier and Type | Field and Description |
|---|---|
protected com.hazelcast.core.DistributedObject |
distributedObject |
lifecycleCondition, lifecycleLock| Constructor and Description |
|---|
AbstractHazelcastMessageProducer(com.hazelcast.core.DistributedObject distributedObject) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Set<java.lang.String> |
getCacheEvents() |
protected CacheListeningPolicyType |
getCacheListeningPolicy() |
protected java.util.UUID |
getHazelcastRegisteredEventListenerId() |
void |
setCacheEventTypes(java.lang.String cacheEventTypes) |
void |
setCacheListeningPolicy(CacheListeningPolicyType cacheListeningPolicy) |
protected void |
setHazelcastRegisteredEventListenerId(java.util.UUID hazelcastRegisteredEventListenerId) |
afterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, 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, toStringprotected final com.hazelcast.core.DistributedObject distributedObject
public AbstractHazelcastMessageProducer(com.hazelcast.core.DistributedObject distributedObject)
protected java.util.Set<java.lang.String> getCacheEvents()
public void setCacheEventTypes(java.lang.String cacheEventTypes)
protected CacheListeningPolicyType getCacheListeningPolicy()
public void setCacheListeningPolicy(CacheListeningPolicyType cacheListeningPolicy)
protected java.util.UUID getHazelcastRegisteredEventListenerId()
protected void setHazelcastRegisteredEventListenerId(java.util.UUID hazelcastRegisteredEventListenerId)