クラス SimpleRabbitListenerContainerFactory
java.lang.ObjectSE
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<C>
org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
- 実装されたすべてのインターフェース:
RabbitListenerContainerFactory<SimpleMessageListenerContainer>
、Aware
、ApplicationContextAware
、ApplicationEventPublisherAware
public class SimpleRabbitListenerContainerFactory
extends AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
通常の
SimpleMessageListenerContainer
を構築するための RabbitListenerContainerFactory
実装。これはほとんどのユーザーにとってデフォルトであり、そのようなコンテナー定義を手動で構築するために使用されるユーザーにとっては適切な移行パスです。
- 導入:
- 1.4
- 作成者:
- Stephane Nicoll, Gary Russell, Artem Bilan, Dustin Schultz, Jeonggi Kim
フィールドサマリー
クラス org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory から継承されたフィールド
counter, logger
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected SimpleMessageListenerContainer
空のコンテナーインスタンスを作成します。protected void
initializeContainer
(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint) さらに、指定されたコンテナーを初期化します。void
setBatchReceiveTimeout
(LongSE batchReceiveTimeout) バッチメッセージを収集するためのタイムアウトのミリ秒数。void
setBatchSize
(IntegerSE batchSize) void
setConcurrentConsumers
(IntegerSE concurrency) void
setConsecutiveActiveTrigger
(IntegerSE minConsecutiveActive) void
setConsecutiveIdleTrigger
(IntegerSE minConsecutiveIdle) void
setConsumerBatchEnabled
(boolean consumerBatchEnabled) リスナーがサポートしている場合、setBatchSize(Integer)
に基づいてメッセージのリストを表示するには、true に設定します。void
setEnforceImmediateAckForManual
(BooleanSE enforceImmediateAckForManual) ImmediateAcknowledgeAmqpException
がスローされたときにAcknowledgeMode.MANUAL
に対してChannel.basicAck(long, boolean)
を強制するには、true
に設定します。void
setMaxConcurrentConsumers
(IntegerSE maxConcurrency) void
setReceiveTimeout
(LongSE receiveTimeout) void
setStartConsumerMinInterval
(LongSE minStartInterval) void
setStopConsumerMinInterval
(LongSE minStopInterval) クラス org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory から継承されたメソッド
createListenerContainer, setAcknowledgeMode, setAfterReceivePostProcessors, setApplicationEventPublisher, setAutoStartup, setBatchingStrategy, setBatchListener, setChannelTransacted, setConnectionFactory, setConsumerTagStrategy, setContainerCustomizer, setDeBatchingEnabled, setErrorHandler, setFailedDeclarationRetryInterval, setForceStop, setGlobalQos, setIdleEventInterval, setMessageAckListener, setMessageConverter, setMismatchedQueuesFatal, setMissingQueuesFatal, setObservationConvention, setPhase, setPrefetchCount, setRecoveryBackOff, setRecoveryInterval, setTaskExecutor, setTransactionManager
クラス 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.context.ApplicationContextAware から継承されたメソッド
setApplicationContext
インターフェース org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory から継承されたメソッド
createListenerContainer
コンストラクターの詳細
SimpleRabbitListenerContainerFactory
public SimpleRabbitListenerContainerFactory()
メソッドの詳細
setBatchSize
- パラメーター:
batchSize
- バッチサイズ。- 導入:
- 2.2
- 関連事項:
setConcurrentConsumers
- パラメーター:
concurrency
- 作成するコンシューマーの最小数。- 関連事項:
setMaxConcurrentConsumers
- パラメーター:
maxConcurrency
- コンシューマーの最大数。- 関連事項:
setStartConsumerMinInterval
- パラメーター:
minStartInterval
- 新しいコンシューマーが起動する最小間隔。- 関連事項:
setStopConsumerMinInterval
- パラメーター:
minStopInterval
- コンシューマーが停止する最小間隔。- 関連事項:
setConsecutiveActiveTrigger
- パラメーター:
minConsecutiveActive
- 新しいコンシューマーをトリガーする連続受信の数。- 関連事項:
setConsecutiveIdleTrigger
- パラメーター:
minConsecutiveIdle
- コンシューマーの停止をトリガーする連続タイムアウトの数。- 関連事項:
setReceiveTimeout
- パラメーター:
receiveTimeout
- タイムアウト。- 関連事項:
setBatchReceiveTimeout
バッチメッセージを収集するためのタイムアウトのミリ秒数。これにより、batchSize がいっぱいになるまでの待ち時間が制限されます。デフォルトは 0 (タイムアウトなし) です。- パラメーター:
batchReceiveTimeout
- バッチメッセージを収集するためのタイムアウト。- 導入:
- 3.1.2
- 関連事項:
setConsumerBatchEnabled
public void setConsumerBatchEnabled(boolean consumerBatchEnabled) リスナーがサポートしている場合、setBatchSize(Integer)
に基づいてメッセージのリストを表示するには、true に設定します。バージョン 3.0 以降、これを true に設定すると、AbstractRabbitListenerContainerFactory.setBatchListener(boolean)
も true になります。- パラメーター:
consumerBatchEnabled
- コンテナーにメッセージバッチを作成する場合は true。- 導入:
- 2.2
- 関連事項:
setEnforceImmediateAckForManual
ImmediateAcknowledgeAmqpException
がスローされたときにAcknowledgeMode.MANUAL
に対してChannel.basicAck(long, boolean)
を強制するには、true
に設定します。これは、現在のマイナーバージョンの動作を壊さないための暫定的な解決策である可能性があります。- パラメーター:
enforceImmediateAckForManual
- ImmediateAcknowledgeAmqpException の MANUAL モードのメッセージを確認するためのフラグ- 導入:
- 3.1.2
createContainerInstance
クラスからコピーされた説明:AbstractRabbitListenerContainerFactory
空のコンテナーインスタンスを作成します。- 次で指定:
- クラス
AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
のcreateContainerInstance
- 戻り値:
- 新しいコンテナーインスタンス。
initializeContainer
protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint) クラスからコピーされた説明:AbstractRabbitListenerContainerFactory
さらに、指定されたコンテナーを初期化します。サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。
- オーバーライド:
- クラス
AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
のinitializeContainer
- パラメーター:
instance
- 構成するコンテナーインスタンス。endpoint
- エンドポイント。