Class RedisOutboundGateway

All Implemented Interfaces:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class RedisOutboundGateway extends AbstractReplyProducingMessageHandler
The Gateway component implementation to perform Redis commands with provided arguments and to return command result.
Since:
4.0
Author:
Artem Bilan, Gary Russell
  • Constructor Details

    • RedisOutboundGateway

      public RedisOutboundGateway(RedisTemplate<?,?> redisTemplate)
    • RedisOutboundGateway

      public RedisOutboundGateway(RedisConnectionFactory connectionFactory)
  • Method Details

    • setArgumentsSerializer

      public void setArgumentsSerializer(RedisSerializer<?> serializer)
    • setCommandExpression

      public void setCommandExpression(Expression commandExpression)
      Parameters:
      commandExpression - the String in SpEL syntax.
      Since:
      4.3
    • setCommandExpressionString

      public void setCommandExpressionString(String commandExpression)
      Parameters:
      commandExpression - the String in SpEL syntax.
      Since:
      4.3
    • setArgumentsStrategy

      public void setArgumentsStrategy(ArgumentsStrategy argumentsStrategy)
    • setIntegrationEvaluationContext

      public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
    • getComponentType

      public String getComponentType()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this method to provide component type information.
      Specified by:
      getComponentType in interface NamedComponent
      Overrides:
      getComponentType in class MessageHandlerSupport
    • doInit

      protected void doInit()
      Overrides:
      doInit in class AbstractReplyProducingMessageHandler
    • handleRequestMessage

      protected Object handleRequestMessage(Message<?> requestMessage)
      Description copied from class: AbstractReplyProducingMessageHandler
      Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.
      Specified by:
      handleRequestMessage in class AbstractReplyProducingMessageHandler
      Parameters:
      requestMessage - The request message.
      Returns:
      The result of handling the message, or null.