org.springframework.integration.redis.outbound
Class RedisPublishingMessageHandler
java.lang.Object
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
|
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 |
RedisPublishingMessageHandler
public RedisPublishingMessageHandler(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
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