public class RedisPublishingMessageHandler extends AbstractMessageHandler implements IntegrationEvaluationContextAware
logger
Constructor and Description |
---|
RedisPublishingMessageHandler(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleMessageInternal(Message<?> message) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setDefaultTopic(String defaultTopic)
Deprecated.
in favor of
setTopicExpression(Expression) or setTopic(String) |
void |
setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
void |
setTopic(String topic) |
void |
setTopicExpression(org.springframework.expression.Expression topicExpression) |
getComponentType, getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public RedisPublishingMessageHandler(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)
setIntegrationEvaluationContext
in interface IntegrationEvaluationContextAware
public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public void setMessageConverter(MessageConverter messageConverter)
@Deprecated public void setDefaultTopic(String defaultTopic)
setTopicExpression(Expression)
or setTopic(String)
public void setTopic(String topic)
public void setTopicExpression(org.springframework.expression.Expression topicExpression)
protected void onInit() throws Exception
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
Exception
protected void handleMessageInternal(Message<?> message) throws Exception
handleMessageInternal
in class AbstractMessageHandler
Exception
Copyright © 2018. All rights reserved.