コンストラクターの詳細

• StreamRabbitListenerContainerFactory

  public StreamRabbitListenerContainerFactory​(com.rabbitmq.stream.Environment environment)

  提供された環境を使用してインスタンスを構築します。

  パラメーター:

  environment - 環境。

メソッドの詳細

• setNativeListener

  public void setNativeListener​(boolean nativeListener)

  ネイティブの RabbitMQ ストリームメッセージをサポートするコンテナーを作成するには、true に設定します。

  パラメーター:

  nativeListener - ネイティブリスナーの場合は true。

• setConsumerCustomizer

  public void setConsumerCustomizer​(ConsumerCustomizer consumerCustomizer)

  コンシューマービルダーをビルドする前にカスタマイズします。

  パラメーター:

  consumerCustomizer - カスタマイザー。

• setContainerCustomizer

  public void setContainerCustomizer​(ContainerCustomizer<StreamListenerContainer> containerCustomizer)

  コンテナーの作成および構成後に呼び出される ContainerCustomizer を設定して、コンテナーをさらにカスタマイズできるようにします。

  パラメーター:

  containerCustomizer - カスタマイザー。

• createListenerContainer

  public StreamListenerContainer createListenerContainer​(RabbitListenerEndpoint endpoint)

  インターフェースからコピーされた説明: RabbitListenerContainerFactory
  指定された RabbitListenerEndpoint の MessageListenerContainer を作成します。

  次で指定:

  インターフェース RabbitListenerContainerFactory<StreamListenerContainer> の createListenerContainer 

  次で指定:

  クラス BaseRabbitListenerContainerFactory<StreamListenerContainer> の createListenerContainer 

  パラメーター:

  endpoint - 構成するエンドポイント。

  戻り値:

  作成したコンテナー。

• createContainerInstance

  protected StreamListenerContainer createContainerInstance()

  リスナーコンテナーのインスタンスを作成します。

  戻り値:

  コンテナー。