org.springframework.integration.redis.outbound
Class RedisPublishingMessageHandler

java.lang.Object
  extended by org.springframework.integration.redis.outbound.RedisPublishingMessageHandler
All Implemented Interfaces:
org.springframework.integration.core.MessageHandler

public class RedisPublishingMessageHandler
extends java.lang.Object
implements org.springframework.integration.core.MessageHandler

Since:
2.1

Constructor Summary
RedisPublishingMessageHandler(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
           
 
Method Summary
 void handleMessage(org.springframework.integration.Message<?> message)
           
 void setDefaultTopic(java.lang.String defaultTopic)
           
 void setMessageConverter(org.springframework.integration.support.converter.MessageConverter messageConverter)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RedisPublishingMessageHandler

public RedisPublishingMessageHandler(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
Method Detail

setMessageConverter

public void setMessageConverter(org.springframework.integration.support.converter.MessageConverter messageConverter)

setDefaultTopic

public void setDefaultTopic(java.lang.String defaultTopic)

handleMessage

public void handleMessage(org.springframework.integration.Message<?> message)
                   throws org.springframework.integration.MessagingException
Specified by:
handleMessage in interface org.springframework.integration.core.MessageHandler
Throws:
org.springframework.integration.MessagingException