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 |
---|---|
void |
RabbitTemplate.handleConfirm(PendingConfirm pendingConfirm,
boolean ack) |
Modifier and Type | Method and Description |
---|---|
void |
RabbitTemplate.removePendingConfirmsReference(com.rabbitmq.client.Channel channel,
SortedMap<Long,PendingConfirm> unconfirmed) |
Modifier and Type | Method and Description |
---|---|
SortedMap<Long,PendingConfirm> |
PublisherCallbackChannelImpl.addListener(PublisherCallbackChannel.Listener listener)
Add the listener and return the internal map of pending confirmations for that listener.
|
SortedMap<Long,PendingConfirm> |
PublisherCallbackChannel.addListener(PublisherCallbackChannel.Listener listener)
Adds a
PublisherCallbackChannel.Listener and returns a reference to
the pending confirms map for that listener's pending
confirms, allowing the Listener to
assess unconfirmed sends at any point in time. |
Modifier and Type | Method and Description |
---|---|
void |
PublisherCallbackChannelImpl.addPendingConfirm(PublisherCallbackChannel.Listener listener,
long seq,
PendingConfirm pendingConfirm) |
void |
PublisherCallbackChannel.addPendingConfirm(PublisherCallbackChannel.Listener listener,
long seq,
PendingConfirm pendingConfirm)
Adds a pending confirmation to this channel's map.
|
void |
PublisherCallbackChannel.Listener.handleConfirm(PendingConfirm pendingConfirm,
boolean ack)
Invoked by the channel when a confirm is received.
|
Modifier and Type | Method and Description |
---|---|
void |
PublisherCallbackChannel.Listener.removePendingConfirmsReference(com.rabbitmq.client.Channel channel,
SortedMap<Long,PendingConfirm> unconfirmed)
When called, this listener must remove all references to the
pending confirm map.
|
Copyright © 2018. All rights reserved.