Package org.springframework.integration.redis.outbound

Class RedisOutboundGateway

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.redis.outbound.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.