コンストラクターの詳細

• ListenerContainerFactoryBean

  public 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)

• 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)

• 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