public class RedisPublishingMessageHandler extends AbstractMessageHandler
logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory) |
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 |
setDefaultTopic(String defaultTopic)
Deprecated.
in favor of
setTopicExpression(Expression) or setTopic(String) |
void |
setIntegrationEvaluationContext(EvaluationContext evaluationContext) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setSerializer(RedisSerializer<?> serializer) |
void |
setTopic(String topic) |
void |
setTopicExpression(Expression topicExpression) |
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 RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory)
public void setSerializer(RedisSerializer<?> serializer)
public void setMessageConverter(MessageConverter messageConverter)
@Deprecated public void setDefaultTopic(String defaultTopic)
setTopicExpression(Expression)
or setTopic(String)
defaultTopic
- The default topic.public void setTopic(String topic)
public void setTopicExpression(Expression topicExpression)
public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
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) throws Exception
handleMessageInternal
in class AbstractMessageHandler
Exception