public class SimpleBatchingStrategy extends Object implements BatchingStrategy
Constructor and Description |
---|
SimpleBatchingStrategy(int batchSize,
int bufferLimit,
long timeout) |
Modifier and Type | Method and Description |
---|---|
MessageBatch |
addToBatch(String exchange,
String routingKey,
Message message)
Add a message to the batch and optionally release the batch.
|
Date |
nextRelease() |
Collection<MessageBatch> |
releaseBatches()
Release batch(es), perhaps due to a timeout.
|
public SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout)
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.public MessageBatch addToBatch(String exchange, String routingKey, Message message)
BatchingStrategy
addToBatch
in interface BatchingStrategy
exchange
- The exchange.routingKey
- The routing key.message
- The message.MessageBatch
), or null if not ready to release.public Date nextRelease()
nextRelease
in interface BatchingStrategy
public Collection<MessageBatch> releaseBatches()
BatchingStrategy
releaseBatches
in interface BatchingStrategy