パッケージ org.springframework.amqp.rabbit.core

クラス BatchingRabbitTemplate

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.RabbitAccessor
org.springframework.amqp.rabbit.core.RabbitTemplate
org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
実装されたすべてのインターフェース:
AmqpTemplate、MessageListener、PublisherCallbackChannel.Listener、RabbitOperations、ChannelAwareMessageListener、ListenerContainerAware、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle
public class BatchingRabbitTemplate extends RabbitTemplate
個々のメッセージをより大きなメッセージにまとめることを許可する RabbitTemplate。すべての send() メソッド ( send(String, String, org.springframework.amqp.core.Message, org.springframework.amqp.rabbit.connection.CorrelationData) を除く) がバッチ処理に適しています。

実験用 - API は変更される場合があります。

導入:
1.4.1
作成者:
Gary Russell

  • コンストラクターの詳細

    • BatchingRabbitTemplate

      public BatchingRabbitTemplate(BatchingStrategy batchingStrategy, TaskScheduler scheduler)
      指定されたパラメーターを使用してインスタンスを作成します。
      パラメーター:
      batchingStrategy - バッチ戦略。
      scheduler - スケジューラー。

    • BatchingRabbitTemplate

      public BatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler)
      指定されたパラメーターを使用してインスタンスを作成します。
      パラメーター:
      connectionFactory - 接続ファクトリ。
      batchingStrategy - バッチ戦略。
      scheduler - スケジューラー。
      導入:
      2.2

  • メソッドの詳細

    • send

      public void send(StringSE exchange, StringSE routingKey, Message message, @Nullable CorrelationData correlationData) throws AmqpException
      インターフェースからコピーされた説明: RabbitOperations
      特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
      次で指定:
      インターフェース RabbitOperations の send 
      オーバーライド:
      クラス RabbitTemplate の send 
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • flush

      public void flush()
      部分的に進行中のバッチをフラッシュします。

    • doStart

      public void doStart()
      クラスからコピーされた説明: RabbitTemplate
      追加の開始アクションを実行します。
      オーバーライド:
      クラス RabbitTemplate の doStart 

    • doStop

      public void doStop()
      クラスからコピーされた説明: RabbitTemplate
      追加の停止アクションを実行します。
      オーバーライド:
      クラス RabbitTemplate の doStop 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 
      次で指定:
      インターフェース RabbitOperations の isRunning 
      オーバーライド:
      クラス RabbitTemplate の isRunning