org.springframework.amqp.rabbit.core.support

Interface BatchingStrategy

All Known Implementing Classes:

SimpleBatchingStrategy

public interface BatchingStrategy

Strategy for batching messages. The methods will never be called concurrently.

Experimental - APIs may change.

Since:

1.4.1

Author:

Gary Russell

Method Summary

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.

Method Detail

addToBatch

MessageBatch addToBatch(String exchange,
                        String routingKey,
                        Message message)

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

Parameters:

exchange - The exchange.

routingKey - The routing key.

message - The message.

Returns:

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

nextRelease

Date nextRelease()

Returns:

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

releaseBatches

Collection<MessageBatch> releaseBatches()

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

Returns:

The batched message(s).