パッケージ org.springframework.rabbit.stream.listener

クラス StreamListenerContainer

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.RabbitAccessor
org.springframework.amqp.rabbit.listener.ObservableListenerContainer
org.springframework.rabbit.stream.listener.StreamListenerContainer
実装されたすべてのインターフェース:
MessageListenerContainer、Aware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle
public class StreamListenerContainer extends ObservableListenerContainer
RabbitMQ Streams のリスナーコンテナー。
導入:
2.4
作成者:
Gary Russell, Christian Tzolov

  • フィールドの詳細

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

    • StreamListenerContainer

      public StreamListenerContainer(com.rabbitmq.stream.Environment environment)
      提供された環境を使用してインスタンスを構築します。
      パラメーター:
      environment - 環境。

    • StreamListenerContainer

      public StreamListenerContainer(com.rabbitmq.stream.Environment environment, @Nullable com.rabbitmq.stream.Codec codec)
      提供された環境とコーデックを使用してインスタンスを構築します。
      パラメーター:
      environment - 環境。
      codec - 返信メッセージの作成に使用されるコーデック。

  • メソッドの詳細

    • setQueueNames

      public void setQueueNames(StringSE... queueNames)
      キュー名を設定します。superStream(String, String) とは相互に排他的です。
      パラメーター:
      queueNames - キュー名。

    • superStream

      public void superStream(StringSE streamName, StringSE name)
      1 つのコンシューマーを使用して、スーパーストリームで単一のアクティブなコンシューマーを有効にします。setQueueNames(String...) とは相互に排他的です。
      パラメーター:
      streamName - ストリーム。
      name - コンシューマー名。
      導入:
      3.0

    • superStream

      public void superStream(StringSE streamName, StringSE name, int consumers)
      指定された数のコンシューマーを使用して、スーパーストリームで単一のアクティブコンシューマーを有効にします。スーパーストリームには少なくともその数のパーティションが必要です。setQueueNames(String...) とは相互に排他的です。
      パラメーター:
      streamName - ストリーム。
      name - コンシューマー名。
      consumers - コンシューマーの数。
      導入:
      3.0

    • getStreamConverter

      public StreamMessageConverter getStreamConverter()
      Message を Message に変換するために使用される StreamMessageConverter を取得します。
      戻り値:
      コンバーター。

    • setStreamConverter

      public void setStreamConverter(StreamMessageConverter messageConverter)
      Message を Message に変換するために使用される StreamMessageConverter を設定します。
      パラメーター:
      messageConverter - コンバーター。

    • setConsumerCustomizer

      public void setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
      コンシューマービルダーをビルドする前にカスタマイズします。
      パラメーター:
      consumerCustomizer - カスタマイザー。

    • setAutoStartup

      public void setAutoStartup(boolean autoStart)
      インターフェースからコピーされた説明: MessageListenerContainer
      自動起動を設定します。
      パラメーター:
      autoStart - 自動開始に真。

    • isAutoStartup

      public boolean isAutoStartup()

    • setAdviceChain

      public void setAdviceChain(Advice... advices)
      リスナーに適用するアドバイスチェーン を設定します。
      パラメーター:
      advices - アドバイスチェーン。
      導入:
      2.4.5

    • getMessageListener

      @Nullable public ObjectSE getMessageListener()
      インターフェースからコピーされた説明: MessageListenerContainer
      メッセージリスナーを取得します。
      戻り値:
      メッセージリスナーオブジェクト。

    • setObservationConvention

      public void setObservationConvention(RabbitStreamListenerObservationConvention observationConvention)
      RabbitStreamListenerObservationConvention を設定します。StreamMessageListener の使用時に追加のキー / 値を観測に追加するために使用されます。
      パラメーター:
      observationConvention - 大会。
      導入:
      3.0.5

    • afterPropertiesSet

      public void afterPropertiesSet()
      次で指定:
      インターフェース InitializingBean の afterPropertiesSet 
      次で指定:
      インターフェース MessageListenerContainer の afterPropertiesSet 
      オーバーライド:
      クラス RabbitAccessor の afterPropertiesSet 

    • isRunning

      public boolean isRunning()

    • start

      public void start()

    • stop

      public void stop()

    • setupMessageListener

      public void setupMessageListener(MessageListener messageListener)
      インターフェースからコピーされた説明: MessageListenerContainer
      使用するメッセージリスナーを設定します。そのメッセージリスナ型がサポートされていない場合、IllegalArgumentExceptionSE をスローします。
      パラメーター:
      messageListener - object を MessageListener にラップします。