クラス RedisQueueOutboundGateway

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>AwareBeanClassLoaderAwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareOrderedExpressionCapableOrderableMessageProducerHeaderPropagationAwareIntegrationPatternNamedComponentIntegrationManagementTrackableComponentMessageHandlerreactor.core.CoreSubscriber<Message<?>>

public class RedisQueueOutboundGateway extends AbstractReplyProducingMessageHandler
導入:
4.1
作成者:
David Liu, Artem Bilan, Gary Russell
  • コンストラクターの詳細

  • メソッドの詳細

    • setBeanClassLoader

      public void setBeanClassLoader(ClassLoaderSE beanClassLoader)
      次で指定:
      インターフェース BeanClassLoaderAwaresetBeanClassLoader 
      オーバーライド:
      クラス AbstractReplyProducingMessageHandlersetBeanClassLoader 
    • setReceiveTimeout

      public void setReceiveTimeout(int timeout)
    • setExtractPayload

      public void setExtractPayload(boolean extractPayload)
    • setSerializer

      public void setSerializer(RedisSerializer<?> serializer)
    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponentgetComponentType 
      オーバーライド:
      クラス MessageHandlerSupportgetComponentType 
    • handleRequestMessage

      @Nullable protected ObjectSE handleRequestMessage(Message<?> message)
      クラスからコピーされた説明: AbstractReplyProducingMessageHandler
      サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
      次で指定:
      クラス AbstractReplyProducingMessageHandlerhandleRequestMessage 
      パラメーター:
      message - リクエストメッセージ。
      戻り値:
      メッセージを処理した結果、または null