クラス RedisQueueOutboundGateway

java.lang.ObjectSE
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.RedisQueueOutboundGateway
実装済みのインターフェース一覧:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
public class RedisQueueOutboundGateway extends AbstractReplyProducingMessageHandler
導入:
4.1
作成者:
David Liu, Artem Bilan, Gary Russell, Glenn Renfro

  • コンストラクターの詳細

  • 方法の詳細

    • setBeanClassLoader

      public void setBeanClassLoader(ClassLoaderSE beanClassLoader)
      次で指定:
      インターフェース BeanClassLoaderAware 内の setBeanClassLoader 
      オーバーライド:
      クラス AbstractReplyProducingMessageHandler の setBeanClassLoader 

    • setReceiveDuration

      public void setReceiveDuration(DurationSE receiveTimeout)
      このタイムアウトは、BoundListOperations で指定されたキューから要素を取得する際に使用されます。

      キューに要素が含まれている場合、データはすぐに取得されます。ただし、キューが空の場合、要素をキューから取得できるか、指定されたタイムアウトが経過するまで、Redis 接続はブロックされます。

      ゼロのタイムアウトは、無期限にブロックするために使用できます。明示的に設定されていない場合、タイムアウト値はデフォルトで 1000 millis になります

      関連事項: https://redis.io/commands/brpop

      パラメーター:
      receiveTimeout - DurationSE には受信タイムアウトが含まれています。
      導入:
      7.1

    • setReceiveTimeout

      @DeprecatedSE(forRemoval=true, since="7.1") public void setReceiveTimeout(int receiveTimeout)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      7.1 以降、setReceiveTimeout(long) を推奨
      このタイムアウトは、BoundListOperations で指定されたキューから要素を取得する際に使用されます。

      キューに要素が含まれている場合、データはすぐに取得されます。ただし、キューが空の場合、要素をキューから取得できるか、指定されたタイムアウトが経過するまで、Redis 接続はブロックされます。

      ゼロのタイムアウトは、無期限にブロックするために使用できます。明示的に設定されていない場合、タイムアウト値はデフォルトで 1000 millis になります

      関連事項: https://redis.io/commands/brpop

      パラメーター:
      receiveTimeout - 負でない必要があります。ミリ秒で指定されます。

    • setReceiveTimeout

      public void setReceiveTimeout(long receiveTimeout)
      このタイムアウトは、BoundListOperations で指定されたキューから要素を取得する際に使用されます。

      キューに要素が含まれている場合、データはすぐに取得されます。ただし、キューが空の場合、要素をキューから取得できるか、指定されたタイムアウトが経過するまで、Redis 接続はブロックされます。

      ゼロのタイムアウトは、無期限にブロックするために使用できます。明示的に設定されていない場合、タイムアウト値はデフォルトで 1000 millis になります

      関連事項: https://redis.io/commands/brpop

      パラメーター:
      receiveTimeout - 負でない必要があります。ミリ秒で指定されます。

    • setExtractPayload

      public void setExtractPayload(boolean extractPayload)

    • setSerializer

      public void setSerializer(RedisSerializer<?> serializer)

    • getComponentType

      public StringSE getComponentType()
      次で指定:
      インターフェース NamedComponent 内の getComponentType 
      オーバーライド:
      クラス MessageHandlerSupport の getComponentType 

    • handleRequestMessage

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