public class CacheWritingMessageHandler extends AbstractMessageHandler
MessageHandler implementation that writes to a GemFire Region. The
Message's payload must be an instance of Map or cacheEntryExpressions
must be provided.logger| Constructor and Description |
|---|
CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleMessageInternal(Message<?> message) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setCacheEntries(java.util.Map<java.lang.String,java.lang.String> cacheEntries) |
void |
setCacheEntryExpressions(java.util.Map<org.springframework.expression.Expression,org.springframework.expression.Expression> cacheEntryExpressions) |
getComponentType, getOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region)
protected void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportjava.lang.Exceptionprotected void handleMessageInternal(Message<?> message)
handleMessageInternal in class AbstractMessageHandlerpublic void setCacheEntries(java.util.Map<java.lang.String,java.lang.String> cacheEntries)
public void setCacheEntryExpressions(java.util.Map<org.springframework.expression.Expression,org.springframework.expression.Expression> cacheEntryExpressions)