public interface BatchingStrategy
Experimental - APIs may change.
| Modifier and Type | Method and Description |
|---|---|
MessageBatch |
addToBatch(java.lang.String exchange,
java.lang.String routingKey,
org.springframework.amqp.core.Message message)
Add a message to the batch and optionally release the batch.
|
java.util.Date |
nextRelease() |
MessageBatch |
releaseBatch()
Release a batch, perhaps due to a timeout.
|
MessageBatch addToBatch(java.lang.String exchange, java.lang.String routingKey, org.springframework.amqp.core.Message message)
exchange - The exchange.routingKey - The routing key.message - The message.MessageBatch), or null if not ready to release.java.util.Date nextRelease()
MessageBatch releaseBatch()
null is returned.