クラス StreamRabbitListenerContainerFactory
java.lang.ObjectSE
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
- 実装されたすべてのインターフェース:
RabbitListenerContainerFactory<StreamListenerContainer>、Aware、ApplicationContextAware
public class StreamRabbitListenerContainerFactory
extends BaseRabbitListenerContainerFactory<StreamListenerContainer>
StreamListenerContainer のファクトリ。
- 導入:
- 2.4
- 作成者:
- Gary Russell
コンストラクターのサマリー
コンストラクターコンストラクター説明StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment) 提供された環境を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明protected StreamListenerContainerリスナーコンテナーのインスタンスを作成します。指定されたRabbitListenerEndpointのMessageListenerContainerを作成します。voidsetConsumerCustomizer(ConsumerCustomizer consumerCustomizer) コンシューマービルダーをビルドする前にカスタマイズします。voidsetContainerCustomizer(ContainerCustomizer<StreamListenerContainer> containerCustomizer) コンテナーの作成および構成後に呼び出されるContainerCustomizerを設定して、コンテナーをさらにカスタマイズできるようにします。voidsetNativeListener(boolean nativeListener) ネイティブの RabbitMQ ストリームメッセージをサポートするコンテナーを作成するには、true に設定します。voidsetStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention) ネイティブストリームメッセージを受信するときに使用されるRabbitStreamListenerObservationConventionを設定します。クラス org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory から継承されたメソッド
applyCommonOverrides, getAdviceChain, getApplicationContext, getDefaultRequeueRejected, getMicrometerEnabled, getObservationEnabled, setAdviceChain, setApplicationContext, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setMicrometerEnabled, setObservationEnabled, setReplyPostProcessorProvider, setReplyRecoveryCallback, setRetryTemplateクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory から継承されたメソッド
createListenerContainer
コンストラクターの詳細
StreamRabbitListenerContainerFactory
public StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment) 提供された環境を使用してインスタンスを構築します。- パラメーター:
environment- 環境。
メソッドの詳細
setNativeListener
public void setNativeListener(boolean nativeListener) ネイティブの RabbitMQ ストリームメッセージをサポートするコンテナーを作成するには、true に設定します。- パラメーター:
nativeListener- ネイティブリスナーの場合は true。
setConsumerCustomizer
コンシューマービルダーをビルドする前にカスタマイズします。- パラメーター:
consumerCustomizer- カスタマイザー。
setContainerCustomizer
public void setContainerCustomizer(ContainerCustomizer<StreamListenerContainer> containerCustomizer) コンテナーの作成および構成後に呼び出されるContainerCustomizerを設定して、コンテナーをさらにカスタマイズできるようにします。- パラメーター:
containerCustomizer- カスタマイザー。
setStreamListenerObservationConvention
public void setStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention) ネイティブストリームメッセージを受信するときに使用されるRabbitStreamListenerObservationConventionを設定します。- パラメーター:
streamListenerObservationConvention- 大会。- 導入:
- 3.0.5
createListenerContainer
インターフェースからコピーされた説明:RabbitListenerContainerFactory指定されたRabbitListenerEndpointのMessageListenerContainerを作成します。- 次で指定:
- インターフェース
RabbitListenerContainerFactory<StreamListenerContainer>のcreateListenerContainer - 次で指定:
- クラス
BaseRabbitListenerContainerFactory<StreamListenerContainer>のcreateListenerContainer - パラメーター:
endpoint- 構成するエンドポイント。- 戻り値:
- 作成したコンテナー。
createContainerInstance
リスナーコンテナーのインスタンスを作成します。- 戻り値:
- コンテナー。