クラス AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>, T extends AbstractAmqpChannel>

メソッドの詳細

• maxSubscribers

  public S maxSubscribers(int maxSubscribers)

  パラメーター:

  maxSubscribers - maxSubscribers。

  戻り値:

  スペック。

  関連事項:

  • AbstractSubscribableAmqpChannel.setMaxSubscribers(int)

• acknowledgeMode

  public S acknowledgeMode(AcknowledgeMode acknowledgeMode)

  パラメーター:

  acknowledgeMode - acknowledgeMode。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)

• advice

  public S advice(Advice... advice)

  パラメーター:

  advice - 助言。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setAdviceChain(Advice[])

• autoStartup

  public S autoStartup(boolean autoStartup)

  パラメーター:

  autoStartup - autoStartup。

  戻り値:

  スペック。

  関連事項:

  • SmartLifecycle

• concurrentConsumers

  public S concurrentConsumers(int concurrentConsumers)

  パラメーター:

  concurrentConsumers - concurrentConsumers

  戻り値:

  スペック。

  関連事項:

  • SimpleMessageListenerContainer.setConcurrentConsumers(int)

• errorHandler

  public S errorHandler(ErrorHandler errorHandler)

  パラメーター:

  errorHandler - errorHandler。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

• exposeListenerChannel

  public S exposeListenerChannel(boolean exposeListenerChannel)

  パラメーター:

  exposeListenerChannel - exposeListenerChannel。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setExposeListenerChannel(boolean)

• phase

  public S phase(int phase)

  パラメーター:

  phase - フェーズ。

  戻り値:

  スペック。

  関連事項:

  • SmartLifecycle

• prefetchCount

  public S prefetchCount(int prefetchCount)

  パラメーター:

  prefetchCount - prefetchCount。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setPrefetchCount(int)

• receiveTimeout

  public S receiveTimeout(long receiveTimeout)

  パラメーター:

  receiveTimeout - receiveTimeout

  戻り値:

  スペック。

  関連事項:

  • SimpleMessageListenerContainer.setReceiveTimeout(long)

• recoveryInterval

  public S recoveryInterval(long recoveryInterval)

  パラメーター:

  recoveryInterval - recoveryInterval

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setRecoveryInterval(long)

• shutdownTimeout

  public S shutdownTimeout(long shutdownTimeout)

  パラメーター:

  shutdownTimeout - shutdownTimeout。

  戻り値:

  スペック。

  関連事項:

  • AbstractMessageListenerContainer.setShutdownTimeout(long)

• taskExecutor

  public S taskExecutor(ExecutorSE taskExecutor)

  メッセージリスナーの呼び出しに使用する ExecutorSE を設定します。

  パラメーター:

  taskExecutor - taskExecutor。

  戻り値:

  スペック。

• transactionAttribute

  public S transactionAttribute(TransactionAttribute transactionAttribute)

  transactionManager(PlatformTransactionManager) で使用するように TransactionAttribute を構成します。

  パラメーター:

  transactionAttribute - transactionAttribute。

  戻り値:

  スペック。

• transactionManager

  public S transactionManager(PlatformTransactionManager transactionManager)

  PlatformTransactionManager を構成します。; rabbit トランザクションを他のトランザクションと同期するために使用されます。

  パラメーター:

  transactionManager - transactionManager。

  戻り値:

  スペック。

• batchSize

  public S batchSize(int batchSize)

  バッチサイズを構成します。

  パラメーター:

  batchSize - batchSize。

  戻り値:

  スペック。

  導入:

  5.2

  関連事項:

  • SimpleMessageListenerContainer.setBatchSize(int)

• doGet

  protected T doGet()

  オーバーライド:

  クラス AmqpPollableMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>, T extends AbstractAmqpChannel> の doGet