public static interface PublisherCallbackChannel.Listener
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getUUID()
Returns the UUID used to identify this Listener for returns.
|
void |
handleConfirm(PendingConfirm pendingConfirm,
boolean ack)
Invoked by the channel when a confirm is received.
|
void |
handleReturn(int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body) |
boolean |
isConfirmListener() |
boolean |
isReturnListener() |
void |
removePendingConfirmsReference(com.rabbitmq.client.Channel channel,
java.util.SortedMap<java.lang.Long,PendingConfirm> unconfirmed)
When called, this listener must remove all references to the
pending confirm map.
|
void handleConfirm(PendingConfirm pendingConfirm, boolean ack)
pendingConfirm - The pending confirmation, containing
correlation data.ack - true when 'ack', false when 'nack'.void handleReturn(int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body)
throws java.io.IOException
java.io.IOExceptionvoid removePendingConfirmsReference(com.rabbitmq.client.Channel channel,
java.util.SortedMap<java.lang.Long,PendingConfirm> unconfirmed)
channel - The channel.unconfirmed - The pending confirm map.java.lang.String getUUID()
boolean isConfirmListener()
boolean isReturnListener()