Spring Integration

org.springframework.integration.gemfire.outbound
Class CacheWritingMessageHandler

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.handler.AbstractMessageHandler
          extended by org.springframework.integration.gemfire.outbound.CacheWritingMessageHandler
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered, NamedComponent, Orderable, MessageHandler, TrackableComponent

public class CacheWritingMessageHandler
extends AbstractMessageHandler

A MessageHandler implementation that writes to a GemFire Region. The Message's payload must be an instance of java.util.Map.

Since:
2.1
Author:
Mark Fisher, David Turanski

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
 
Constructor Summary
CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region)
           
 
Method Summary
 void handleMessageInternal(Message<?> message)
           
 void setCacheEntries(java.util.Map<java.lang.String,java.lang.String> cacheEntries)
           
 
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
getComponentType, getOrder, handleMessage, setOrder, setShouldTrack
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, setConversionService, 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.context.NamedComponent
getComponentName
 

Constructor Detail

CacheWritingMessageHandler

public CacheWritingMessageHandler(com.gemstone.gemfire.cache.Region region)
Method Detail

handleMessageInternal

public void handleMessageInternal(Message<?> message)
Specified by:
handleMessageInternal in class AbstractMessageHandler

setCacheEntries

public void setCacheEntries(java.util.Map<java.lang.String,java.lang.String> cacheEntries)

Spring Integration