org.springframework.amqp.rabbit.core.support

Class SimpleBatchingStrategy

java.lang.Object

org.springframework.amqp.rabbit.core.support.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

Constructor Summary

Constructors

Constructor and Description
SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout)

Method Summary

Modifier and Type	Method and Description
MessageBatch	addToBatch(java.lang.String exchange, java.lang.String routingKey, Message message) Add a message to the batch and optionally release the batch.
java.util.Date	nextRelease()
java.util.Collection<MessageBatch>	releaseBatches() Release batch(es), perhaps due to a timeout.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleBatchingStrategy

public SimpleBatchingStrategy(int batchSize,
                              int bufferLimit,
                              long timeout)

Parameters:

batchSize - the batch size.

bufferLimit - the max buffer size; could trigger a short batch. Does not apply to a single message.

timeout - the batch timeout.

Method Detail

addToBatch

public MessageBatch addToBatch(java.lang.String exchange,
                               java.lang.String routingKey,
                               Message message)

Description copied from interface: BatchingStrategy

Add a message to the batch and optionally release the batch.

Specified by:

addToBatch in interface BatchingStrategy

Parameters:

exchange - The exchange.

routingKey - The routing key.

message - The message.

Returns:

The batched message (MessageBatch), or null if not ready to release.

nextRelease

public java.util.Date nextRelease()

Specified by:

nextRelease in interface BatchingStrategy

Returns:

the date the next scheduled release should run, or null if no data to release.

releaseBatches

public java.util.Collection<MessageBatch> releaseBatches()

Description copied from interface: BatchingStrategy

Release batch(es), perhaps due to a timeout.

Specified by:

releaseBatches in interface BatchingStrategy

Returns:

The batched message(s).