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