クラス ListenerContainerFactoryBean

メソッドの詳細

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• setBeanName

  public void setBeanName(StringSE beanName)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setType

  public void setType(ListenerContainerFactoryBean.Type type)

• setConnectionFactory

  public void setConnectionFactory(ConnectionFactory connectionFactory)

• setChannelTransacted

  public void setChannelTransacted(boolean transactional)

• setAcknowledgeMode

  public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)

• setQueueNames

  public void setQueueNames(StringSE... queueName)

• setQueues

  public void setQueues(Queue... queues)

• setExposeListenerChannel

  public void setExposeListenerChannel(boolean exposeListenerChannel)

• setMessageListener

  public void setMessageListener(MessageListener messageListener)

• setErrorHandler

  public void setErrorHandler(ErrorHandler errorHandler)

• setDeBatchingEnabled

  public void setDeBatchingEnabled(boolean deBatchingEnabled)

• setAdviceChain

  public void setAdviceChain(Advice... adviceChain)

• setAfterReceivePostProcessors

  public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)

• setAutoStartup

  public void setAutoStartup(boolean autoStartup)

• setPhase

  public void setPhase(int phase)

• setListenerId

  public void setListenerId(StringSE listenerId)

• setConsumerTagStrategy

  public void setConsumerTagStrategy(ConsumerTagStrategy consumerTagStrategy)

• setConsumerArguments

  public void setConsumerArguments(MapSE<StringSE,ObjectSE> args)

• setNoLocal

  public void setNoLocal(BooleanSE noLocal)

• setExclusive

  public void setExclusive(boolean exclusive)

• setDefaultRequeueRejected

  public void setDefaultRequeueRejected(boolean defaultRequeueRejected)

• setPrefetchCount

  public void setPrefetchCount(int prefetchCount)

• setGlobalQos

  public void setGlobalQos(boolean globalQos)

  チャネル全体にプリフェッチを適用します。

  パラメーター:

  globalQos - チャネル全体のプリフェッチの場合は true。

  導入:

  2.2.17

  関連事項:

  • Channel.basicQos(int, boolean)

• setShutdownTimeout

  public void setShutdownTimeout(long shutdownTimeout)

• setIdleEventInterval

  public void setIdleEventInterval(long idleEventInterval)

• setTransactionManager

  public void setTransactionManager(PlatformTransactionManager transactionManager)

• setTransactionAttribute

  public void setTransactionAttribute(TransactionAttribute transactionAttribute)

• setTaskExecutor

  public void setTaskExecutor(ExecutorSE taskExecutor)

• setRecoveryInterval

  public void setRecoveryInterval(long recoveryInterval)

• setRecoveryBackOff

  public void setRecoveryBackOff(BackOff recoveryBackOff)

• setMessagePropertiesConverter

  public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)

• setRabbitAdmin

  public void setRabbitAdmin(RabbitAdmin rabbitAdmin)

• setMissingQueuesFatal

  public void setMissingQueuesFatal(boolean missingQueuesFatal)

• setPossibleAuthenticationFailureFatal

  public void setPossibleAuthenticationFailureFatal(BooleanSE possibleAuthenticationFailureFatal)

• setMismatchedQueuesFatal

  public void setMismatchedQueuesFatal(boolean mismatchedQueuesFatal)

• setAutoDeclare

  public void setAutoDeclare(boolean autoDeclare)

• setFailedDeclarationRetryInterval

  public void setFailedDeclarationRetryInterval(long failedDeclarationRetryInterval)

• setExclusiveConsumerExceptionLogger

  public void setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger exclusiveConsumerExceptionLogger)

• setConsumersPerQueue

  public void setConsumersPerQueue(int consumersPerQueue)

• setTaskScheduler

  public void setTaskScheduler(TaskScheduler taskScheduler)

• setMonitorInterval

  public void setMonitorInterval(long monitorInterval)

• setConcurrentConsumers

  public void setConcurrentConsumers(int concurrentConsumers)

• setMaxConcurrentConsumers

  public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

• setStartConsumerMinInterval

  public void setStartConsumerMinInterval(long startConsumerMinInterval)

• setStopConsumerMinInterval

  public void setStopConsumerMinInterval(long stopConsumerMinInterval)

• setConsecutiveActiveTrigger

  public void setConsecutiveActiveTrigger(int consecutiveActiveTrigger)

• setConsecutiveIdleTrigger

  public void setConsecutiveIdleTrigger(int consecutiveIdleTrigger)

• setReceiveTimeout

  public void setReceiveTimeout(long receiveTimeout)

• setBatchReceiveTimeout

  public void setBatchReceiveTimeout(long batchReceiveTimeout)

  バッチメッセージを収集するためのタイムアウトのミリ秒数。これにより、batchSize がいっぱいになるまでの待ち時間が制限されます。デフォルトは 0 (タイムアウトなし) です。

  パラメーター:

  batchReceiveTimeout - バッチメッセージを収集するためのタイムアウト。

  導入:

  3.1.2

  関連事項:

  • setBatchSize(int)

• setBatchSize

  public void setBatchSize(int batchSize)

  このプロパティにはいくつかの機能があります。

  チャネルが処理されると、1 つのトランザクションで処理するメッセージの数が決定されます。the prefetch count 以下である必要があります。

  また、AcknowledgeMode.AUTO を使用する場合に ACK が送信される頻度にも影響します (BatchSize ごとに 1 つの ACK)。

  最後に、setConsumerBatchEnabled(boolean) が true の場合、setReceiveTimeout(long) 内に十分なメッセージが到着する限り、バッチに含めるレコードの数を決定します。

  重要バッチサイズは、受信した物理メッセージの数を表します。setDeBatchingEnabled(boolean) が true で、メッセージがプロデューサーによって作成されたバッチである場合、リスナーによって受信される実際のメッセージ数は、このバッチサイズよりも大きくなります。

  デフォルトは 1 です。

  パラメーター:

  batchSize - バッチサイズ

  導入:

  2.2

• setConsumerBatchEnabled

  public void setConsumerBatchEnabled(boolean consumerBatchEnabled)

  コンテナーとリスナーがサポートしている場合、setBatchSize(int) に基づいてメッセージのリストを表示するには、true に設定します。

  パラメーター:

  consumerBatchEnabled - コンテナーにメッセージバッチを作成する場合は true。

  導入:

  2.2

  関連事項:

  • setBatchSize(int)

• setDeclarationRetries

  public void setDeclarationRetries(int declarationRetries)

• setRetryDeclarationInterval

  public void setRetryDeclarationInterval(long retryDeclarationInterval)

• setMicrometerEnabled

  public void setMicrometerEnabled(boolean enabled)

  micrometer リスナータイマーを無効にするには、false に設定します。

  パラメーター:

  enabled - 無効にする場合は false。

  導入:

  2.4.6

• setMicrometerTags

  public void setMicrometerTags(MapSE<StringSE,StringSE> tags)

  Micrometer リスナータイマーに追加のタグを設定します。

  パラメーター:

  tags - タグ。

  導入:

  2.4.6

• setSMLCCustomizer

  public void setSMLCCustomizer(ContainerCustomizer<SimpleMessageListenerContainer> customizer)

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

  パラメーター:

  customizer - カスタマイザー。

  導入:

  2.4.6

• setDMLCCustomizer

  public void setDMLCCustomizer(ContainerCustomizer<DirectMessageListenerContainer> customizer)

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

  パラメーター:

  customizer - カスタマイザー。

  導入:

  2.4.6

• getObjectType

  public ClassSE<?> getObjectType()

  次で指定:

  インターフェース FactoryBean<AbstractMessageListenerContainer> の getObjectType 

  次で指定:

  クラス AbstractFactoryBean<AbstractMessageListenerContainer> の getObjectType 

• createInstance

  protected AbstractMessageListenerContainer createInstance()

  次で指定:

  クラス AbstractFactoryBean<AbstractMessageListenerContainer> の createInstance 

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• getPhase

  public int getPhase()

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

• isAutoStartup

  public boolean isAutoStartup()

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

• stop

  public void stop(RunnableSE callback)

  次で指定:

  インターフェース SmartLifecycle の stop