public interface PublisherCallbackChannel
extends com.rabbitmq.client.Channel
Modifier and Type | Interface and Description |
---|---|
static interface |
PublisherCallbackChannel.Listener
Listeners implementing this interface can participate
in publisher confirms received from multiple channels,
by invoking addListener on each channel.
|
Modifier and Type | Field and Description |
---|---|
static String |
RETURN_CORRELATION |
Modifier and Type | Method and Description |
---|---|
SortedMap<Long,PendingConfirm> |
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. |
void |
addPendingConfirm(PublisherCallbackChannel.Listener listener,
long seq,
PendingConfirm pendingConfirm)
Adds a pending confirmation to this channel's map.
|
boolean |
removeListener(PublisherCallbackChannel.Listener listener)
Gets a reference to the current listener, or null.
|
abort, abort, addConfirmListener, addFlowListener, addReturnListener, asyncRpc, basicAck, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicNack, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicRecover, basicRecover, basicRecoverAsync, basicReject, clearConfirmListeners, clearFlowListeners, clearReturnListeners, close, close, confirmSelect, exchangeBind, exchangeBind, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclarePassive, exchangeDelete, exchangeDelete, exchangeUnbind, exchangeUnbind, flow, getChannelNumber, getConnection, getDefaultConsumer, getFlow, getNextPublishSeqNo, queueBind, queueBind, queueDeclare, queueDeclare, queueDeclarePassive, queueDelete, queueDelete, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeFlowListener, removeReturnListener, rpc, setDefaultConsumer, txCommit, txRollback, txSelect, waitForConfirms, waitForConfirms, waitForConfirmsOrDie, waitForConfirmsOrDie
static final String RETURN_CORRELATION
SortedMap<Long,PendingConfirm> addListener(PublisherCallbackChannel.Listener listener)
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.
The client must NOT modify the contents of
this array, and must synchronize on it when
iterating over its collections.listener
- The Listener.boolean removeListener(PublisherCallbackChannel.Listener listener)
void addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
seq
- The key to the map.pendingConfirm
- The PendingConfirm object.