public interface BatchingStrategy
Experimental - APIs may change.
| 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.
|
MessageBatch addToBatch(String exchange, String routingKey, Message message)
exchange - The exchange.routingKey - The routing key.message - The message.MessageBatch), or null if not ready to release.Date nextRelease()
Collection<MessageBatch> releaseBatches()