public class BatchingRabbitTemplate extends RabbitTemplate implements Lifecycle
RabbitTemplate
that permits batching individual messages into a larger
message. All send()
methods (except
send(String, String, org.springframework.amqp.core.Message,
org.springframework.amqp.rabbit.support.CorrelationData)
)
are eligible for batching.
Experimental - APIs may change.
RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback
logger
Constructor and Description |
---|
BatchingRabbitTemplate(BatchingStrategy batchingStrategy,
TaskScheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
void |
flush()
Flush any partial in-progress batches.
|
boolean |
isRunning() |
void |
send(String exchange,
String routingKey,
Message message,
CorrelationData correlationData) |
void |
start() |
void |
stop() |
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertMessageIfNecessary, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceiveRaw, correlationconvertAndSend, correlationConvertAndSend, determineConfirmsReturnsCapability, doReceiveNoWait, doSend, doSendAndReceive, doSendAndReceiveWithFixed, doSendAndReceiveWithTemporary, execute, expectedQueueNames, getExchange, getMessageConverter, getRoutingKey, getUnconfirmed, getUUID, handleConfirm, handleReturn, initDefaultStrategies, isChannelLocallyTransacted, isConfirmListener, isReturnListener, onMessage, receive, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, revoke, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, setAfterReceivePostProcessor, setAfterReceivePostProcessors, setBeanFactory, setBeforePublishPostProcessors, setConfirmCallback, setCorrelationDataPostProcessor, setCorrelationKey, setEncoding, setExchange, setMandatory, setMandatoryExpression, setMessageConverter, setMessagePropertiesConverter, setQueue, setReceiveConnectionFactorySelectorExpression, setReceiveTimeout, setRecoveryCallback, setReplyAddress, setReplyQueue, setReplyTimeout, setRetryTemplate, setReturnCallback, setRoutingKey, setSendConnectionFactorySelectorExpression, setUserIdExpression, setUserIdExpressionString, setUseTemporaryReplyQueues, useDirectReplyTo
afterPropertiesSet, convertRabbitAccessException, createConnection, getChannel, getConnection, getConnectionFactory, getTransactionalResourceHolder, isChannelTransacted, setChannelTransacted, setConnectionFactory
public BatchingRabbitTemplate(BatchingStrategy batchingStrategy, TaskScheduler scheduler)
batchingStrategy
- the batching strategy.scheduler
- the scheduler.public void send(String exchange, String routingKey, Message message, CorrelationData correlationData) throws AmqpException
send
in class RabbitTemplate
AmqpException
public void flush()