クラス 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
フィールドサマリー
クラス org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory から継承されたフィールド
counter, logger
コンストラクターのサマリー
コンストラクター コンストラクター 説明 SimpleRabbitListenerContainerFactory()
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 protected SimpleMessageListenerContainer
createContainerInstance()
空のコンテナーインスタンスを作成します。protected void
initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint)
さらに、指定されたコンテナーを初期化します。void
setBatchSize(IntegerSE batchSize)
void
setConcurrentConsumers(IntegerSE concurrency)
void
setConsecutiveActiveTrigger(IntegerSE minConsecutiveActive)
void
setConsecutiveIdleTrigger(IntegerSE minConsecutiveIdle)
void
setConsumerBatchEnabled(boolean consumerBatchEnabled)
リスナーがサポートしている場合、setBatchSize(Integer)
に基づいてメッセージのリストを表示するには、true に設定します。void
setMaxConcurrentConsumers(IntegerSE maxConcurrency)
void
setReceiveTimeout(LongSE receiveTimeout)
void
setStartConsumerMinInterval(LongSE minStartInterval)
void
setStopConsumerMinInterval(LongSE minStopInterval)
クラス org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory から継承されたメソッド
createListenerContainer, getAdviceChain, setAcknowledgeMode, setAdviceChain, setAfterReceivePostProcessors, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchingStrategy, setBatchListener, setChannelTransacted, setConnectionFactory, setConsumerTagStrategy, setContainerCustomizer, setDeBatchingEnabled, setErrorHandler, setFailedDeclarationRetryInterval, setGlobalQos, setIdleEventInterval, setMessageConverter, setMismatchedQueuesFatal, setMissingQueuesFatal, setPhase, setPrefetchCount, setRecoveryBackOff, setRecoveryInterval, setTaskExecutor, setTransactionManager
クラス org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory から継承されたメソッド
applyCommonOverrides, getDefaultRequeueRejected, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setReplyRecoveryCallback, setRetryTemplate
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory から継承されたメソッド
createListenerContainer
メソッドの詳細
setBatchSize
public void setBatchSize(IntegerSE batchSize)
- パラメーター:
batchSize
- バッチサイズ。- 導入:
- 2.2
- 関連事項:
SimpleMessageListenerContainer.setBatchSize(int)
setConcurrentConsumers
public void setConcurrentConsumers(IntegerSE concurrency)
- パラメーター:
concurrency
- 作成するコンシューマーの最小数。- 関連事項:
SimpleMessageListenerContainer.setConcurrentConsumers(int)
setMaxConcurrentConsumers
public void setMaxConcurrentConsumers(IntegerSE maxConcurrency)
- パラメーター:
maxConcurrency
- コンシューマーの最大数。- 関連事項:
SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
setStartConsumerMinInterval
public void setStartConsumerMinInterval(LongSE minStartInterval)
- パラメーター:
minStartInterval
- 新しいコンシューマーが起動する最小間隔。- 関連事項:
SimpleMessageListenerContainer.setStartConsumerMinInterval(long)
setStopConsumerMinInterval
public void setStopConsumerMinInterval(LongSE minStopInterval)
- パラメーター:
minStopInterval
- コンシューマーが停止する最小間隔。- 関連事項:
SimpleMessageListenerContainer.setStopConsumerMinInterval(long)
setConsecutiveActiveTrigger
public void setConsecutiveActiveTrigger(IntegerSE minConsecutiveActive)
- パラメーター:
minConsecutiveActive
- 新しいコンシューマーをトリガーする連続受信の数。- 関連事項:
SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)
setConsecutiveIdleTrigger
public void setConsecutiveIdleTrigger(IntegerSE minConsecutiveIdle)
- パラメーター:
minConsecutiveIdle
- コンシューマーの停止をトリガーする連続タイムアウトの数。- 関連事項:
SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)
setReceiveTimeout
public void setReceiveTimeout(LongSE receiveTimeout)
- パラメーター:
receiveTimeout
- タイムアウト。- 関連事項:
SimpleMessageListenerContainer.setReceiveTimeout(long)
setConsumerBatchEnabled
public void setConsumerBatchEnabled(boolean consumerBatchEnabled)
リスナーがサポートしている場合、setBatchSize(Integer)
に基づいてメッセージのリストを表示するには、true に設定します。- パラメーター:
consumerBatchEnabled
- コンテナーにメッセージバッチを作成する場合は true。- 導入:
- 2.2
- 関連事項:
setBatchSize(Integer)
createContainerInstance
protected SimpleMessageListenerContainer createContainerInstance()
クラスからコピーされた説明:AbstractRabbitListenerContainerFactory
空のコンテナーインスタンスを作成します。- 次で指定:
- クラス
AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
のcreateContainerInstance
- 戻り値:
- 新しいコンテナーインスタンス。
initializeContainer
protected void initializeContainer(SimpleMessageListenerContainer instance, RabbitListenerEndpoint endpoint)
クラスからコピーされた説明:AbstractRabbitListenerContainerFactory
さらに、指定されたコンテナーを初期化します。サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。
- オーバーライド:
- クラス
AbstractRabbitListenerContainerFactory<SimpleMessageListenerContainer>
のinitializeContainer
- パラメーター:
instance
- 構成するコンテナーインスタンス。endpoint
- エンドポイント。