Class BatchingRabbitTemplate

All Implemented Interfaces:
AmqpTemplate, MessageListener, PublisherCallbackChannel.Listener, RabbitOperations, ChannelAwareMessageListener, ListenerContainerAware, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle

public class BatchingRabbitTemplate extends RabbitTemplate
A RabbitTemplate that permits batching individual messages into a larger message. All send() methods (except send(String, String, org.springframework.amqp.core.Message, org.springframework.amqp.rabbit.connection.CorrelationData)) are eligible for batching.

Experimental - APIs may change.

Since:
1.4.1
Author:
Gary Russell
  • Constructor Details

    • BatchingRabbitTemplate

      public BatchingRabbitTemplate(BatchingStrategy batchingStrategy, TaskScheduler scheduler)
      Create an instance with the supplied parameters.
      Parameters:
      batchingStrategy - the batching strategy.
      scheduler - the scheduler.
    • BatchingRabbitTemplate

      public BatchingRabbitTemplate(ConnectionFactory connectionFactory, BatchingStrategy batchingStrategy, TaskScheduler scheduler)
      Create an instance with the supplied parameters.
      Parameters:
      connectionFactory - the connection factory.
      batchingStrategy - the batching strategy.
      scheduler - the scheduler.
      Since:
      2.2
  • Method Details