public abstract class AbstractHazelcastMessageProducer
extends org.springframework.integration.endpoint.MessageProducerSupport
| Modifier and Type | Class and Description |
|---|---|
protected class |
AbstractHazelcastMessageProducer.AbstractHazelcastEventListener<E> |
protected class |
AbstractHazelcastMessageProducer.HazelcastEntryListener<K,V> |
| Modifier and Type | Field and Description |
|---|---|
protected com.hazelcast.core.DistributedObject |
distributedObject |
| 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.lang.String |
getHazelcastRegisteredEventListenerId() |
void |
setCacheEventTypes(java.lang.String cacheEventTypes) |
void |
setCacheListeningPolicy(CacheListeningPolicyType cacheListeningPolicy) |
protected void |
setHazelcastRegisteredEventListenerId(java.lang.String hazelcastRegisteredEventListenerId) |
doStart, doStop, onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackdoStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, 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.lang.String getHazelcastRegisteredEventListenerId()
protected void setHazelcastRegisteredEventListenerId(java.lang.String hazelcastRegisteredEventListenerId)