public class RedisOutboundGateway extends AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
RedisOutboundGateway(RedisConnectionFactory connectionFactory) |
RedisOutboundGateway(RedisTemplate<?,?> redisTemplate) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doInit() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setArgumentsSerializer(RedisSerializer<?> serializer) |
void | setArgumentsStrategy(ArgumentsStrategy argumentsStrategy) |
void | setCommandExpression(Expression commandExpression) |
void | setCommandExpressionString(StringSE commandExpression) |
void | setIntegrationEvaluationContext(EvaluationContext evaluationContext) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, 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 RedisOutboundGateway(RedisTemplate<?,?> redisTemplate)
public RedisOutboundGateway(RedisConnectionFactory connectionFactory)
public void setArgumentsSerializer(RedisSerializer<?> serializer)
public void setCommandExpression(Expression commandExpression)
commandExpression
- SpEL 構文の文字列。public void setCommandExpressionString(StringSE commandExpression)
commandExpression
- SpEL 構文の文字列。public void setArgumentsStrategy(ArgumentsStrategy argumentsStrategy)
public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
protected void doInit()
AbstractReplyProducingMessageHandler
の doInit
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null