public class RedisPublishingMessageHandler extends AbstractMessageHandler
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory) |
修飾子と型 | メソッドと説明 |
---|---|
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
protected void | handleMessageInternal(Message<?> message) |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setIntegrationEvaluationContext(EvaluationContext evaluationContext) |
void | setMessageConverter(MessageConverter messageConverter) |
void | setSerializer(RedisSerializer<?> serializer) |
void | setTopic(StringSE topic) |
void | setTopicExpression(Expression topicExpression) |
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getThisAs
getBeanName, getComponentName
public RedisPublishingMessageHandler(RedisConnectionFactory connectionFactory)
public void setSerializer(RedisSerializer<?> serializer)
public void setMessageConverter(MessageConverter messageConverter)
public void setTopic(StringSE topic)
public void setTopicExpression(Expression topicExpression)
public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
protected void onInit()
IntegrationObjectSupport
IntegrationObjectSupport
の onInit
protected void handleMessageInternal(Message<?> message)
AbstractMessageHandler
の handleMessageInternal