| Package | Description |
|---|---|
| org.springframework.amqp.rabbit.core |
Provides core classes for Spring Rabbit.
|
| org.springframework.amqp.rabbit.support |
Provides support classes for Spring Rabbit.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Collection<CorrelationData> |
RabbitTemplate.getUnconfirmed(long age)
Gets unconfirmed correlatiom data older than age and removes them.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RabbitTemplate.ConfirmCallback.confirm(CorrelationData correlationData,
boolean ack) |
void |
RabbitTemplate.convertAndSend(java.lang.String routingKey,
java.lang.Object object,
CorrelationData correlationData) |
void |
RabbitTemplate.convertAndSend(java.lang.String routingKey,
java.lang.Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData) |
void |
RabbitTemplate.convertAndSend(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object object,
CorrelationData correlationData) |
void |
RabbitTemplate.convertAndSend(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData) |
void |
RabbitTemplate.correlationconvertAndSend(java.lang.Object object,
CorrelationData correlationData)
Deprecated.
|
void |
RabbitTemplate.correlationConvertAndSend(java.lang.Object object,
CorrelationData correlationData) |
protected void |
RabbitTemplate.doSend(com.rabbitmq.client.Channel channel,
java.lang.String exchange,
java.lang.String routingKey,
Message message,
CorrelationData correlationData)
Send the given message to the specified exchange.
|
void |
RabbitTemplate.send(java.lang.String exchange,
java.lang.String routingKey,
Message message,
CorrelationData correlationData) |
| Modifier and Type | Field and Description |
|---|---|
private CorrelationData |
PendingConfirm.correlationData |
| Modifier and Type | Method and Description |
|---|---|
CorrelationData |
PendingConfirm.getCorrelationData()
The correlation data supplied by the client when sending the message
corresponding to this confirmation.
|
| Constructor and Description |
|---|
PendingConfirm(CorrelationData correlationData,
long timestamp) |