Class SimpleBatchingStrategy

  • All Implemented Interfaces:
    BatchingStrategy

    public class SimpleBatchingStrategy
    extends java.lang.Object
    implements BatchingStrategy
    A simple batching strategy that supports only one exchange/routingKey; includes a batch size, a batched message size limit and a timeout. The message properties from the first message in the batch is used in the batch message. Each message is preceded by a 4 byte length field.
    Since:
    1.4.1
    Author:
    Gary Russell