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
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region) |
Modifier and Type | Method and Description |
---|---|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
handleMessageInternal(Message<?> message) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setCacheEntries(Map<String,String> cacheEntries) |
void |
setCacheEntryExpressions(Map<Expression,Expression> cacheEntryExpressions) |
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region)
public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected void onInit() throws Exception
IntegrationObjectSupport
onInit
in class AbstractMessageHandler
Exception
- Any exception.protected void handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractMessageHandler
public void setCacheEntryExpressions(Map<Expression,Expression> cacheEntryExpressions)