org.springframework.amqp.rabbit.support
Class PublisherCallbackChannelImpl
java.lang.Object
org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
- All Implemented Interfaces:
- com.rabbitmq.client.Channel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener, com.rabbitmq.client.ShutdownNotifier, PublisherCallbackChannel
public class PublisherCallbackChannelImpl
- extends Object
- implements PublisherCallbackChannel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener
Channel wrapper to allow a single listener able to handle
confirms from multiple channels.
- Since:
- 1.0.1
- Author:
- Gary Russell
|
Method Summary |
void |
abort()
|
void |
abort(int closeCode,
String closeMessage)
|
void |
addConfirmListener(com.rabbitmq.client.ConfirmListener listener)
|
void |
addFlowListener(com.rabbitmq.client.FlowListener listener)
|
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. |
void |
addReturnListener(com.rabbitmq.client.ReturnListener listener)
|
void |
addShutdownListener(com.rabbitmq.client.ShutdownListener listener)
|
void |
asyncRpc(com.rabbitmq.client.Method method)
|
void |
basicAck(long deliveryTag,
boolean multiple)
|
void |
basicCancel(String consumerTag)
|
String |
basicConsume(String queue,
boolean autoAck,
com.rabbitmq.client.Consumer callback)
|
String |
basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
com.rabbitmq.client.Consumer callback)
|
String |
basicConsume(String queue,
boolean autoAck,
String consumerTag,
com.rabbitmq.client.Consumer callback)
|
String |
basicConsume(String queue,
com.rabbitmq.client.Consumer callback)
|
com.rabbitmq.client.GetResponse |
basicGet(String queue,
boolean autoAck)
|
void |
basicNack(long deliveryTag,
boolean multiple,
boolean requeue)
|
void |
basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
|
void |
basicPublish(String exchange,
String routingKey,
boolean mandatory,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
|
void |
basicPublish(String exchange,
String routingKey,
boolean mandatory,
boolean immediate,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
|
void |
basicQos(int prefetchCount)
|
void |
basicQos(int prefetchSize,
int prefetchCount,
boolean global)
|
com.rabbitmq.client.AMQP.Basic.RecoverOk |
basicRecover()
|
com.rabbitmq.client.AMQP.Basic.RecoverOk |
basicRecover(boolean requeue)
|
void |
basicRecoverAsync(boolean requeue)
|
void |
basicReject(long deliveryTag,
boolean requeue)
|
void |
clearConfirmListeners()
|
void |
clearFlowListeners()
|
void |
clearReturnListeners()
|
void |
close()
|
void |
close(int closeCode,
String closeMessage)
|
com.rabbitmq.client.AMQP.Confirm.SelectOk |
confirmSelect()
|
boolean |
equals(Object obj)
|
com.rabbitmq.client.AMQP.Exchange.BindOk |
exchangeBind(String destination,
String source,
String routingKey)
|
com.rabbitmq.client.AMQP.Exchange.BindOk |
exchangeBind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(String exchange,
String type)
|
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(String exchange,
String type,
boolean durable)
|
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
boolean internal,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclarePassive(String name)
|
com.rabbitmq.client.AMQP.Exchange.DeleteOk |
exchangeDelete(String exchange)
|
com.rabbitmq.client.AMQP.Exchange.DeleteOk |
exchangeDelete(String exchange,
boolean ifUnused)
|
com.rabbitmq.client.AMQP.Exchange.UnbindOk |
exchangeUnbind(String destination,
String source,
String routingKey)
|
com.rabbitmq.client.AMQP.Exchange.UnbindOk |
exchangeUnbind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Channel.FlowOk |
flow(boolean active)
|
int |
getChannelNumber()
|
com.rabbitmq.client.ShutdownSignalException |
getCloseReason()
|
com.rabbitmq.client.Connection |
getConnection()
|
com.rabbitmq.client.Consumer |
getDefaultConsumer()
|
com.rabbitmq.client.AMQP.Channel.FlowOk |
getFlow()
|
long |
getNextPublishSeqNo()
|
void |
handleAck(long seq,
boolean multiple)
|
void |
handleNack(long seq,
boolean multiple)
|
void |
handleReturn(int replyCode,
String replyText,
String exchange,
String routingKey,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body)
|
int |
hashCode()
|
boolean |
isOpen()
|
void |
notifyListeners()
|
com.rabbitmq.client.AMQP.Queue.BindOk |
queueBind(String queue,
String exchange,
String routingKey)
|
com.rabbitmq.client.AMQP.Queue.BindOk |
queueBind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclare()
|
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Map<String,Object> arguments)
|
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclarePassive(String queue)
|
com.rabbitmq.client.AMQP.Queue.DeleteOk |
queueDelete(String queue)
|
com.rabbitmq.client.AMQP.Queue.DeleteOk |
queueDelete(String queue,
boolean ifUnused,
boolean ifEmpty)
|
com.rabbitmq.client.AMQP.Queue.PurgeOk |
queuePurge(String queue)
|
com.rabbitmq.client.AMQP.Queue.UnbindOk |
queueUnbind(String queue,
String exchange,
String routingKey)
|
com.rabbitmq.client.AMQP.Queue.UnbindOk |
queueUnbind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
|
boolean |
removeConfirmListener(com.rabbitmq.client.ConfirmListener listener)
|
boolean |
removeFlowListener(com.rabbitmq.client.FlowListener listener)
|
boolean |
removeListener(PublisherCallbackChannel.Listener listener)
Gets a reference to the current listener, or null. |
boolean |
removeReturnListener(com.rabbitmq.client.ReturnListener listener)
|
void |
removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)
|
com.rabbitmq.client.Command |
rpc(com.rabbitmq.client.Method method)
|
void |
setDefaultConsumer(com.rabbitmq.client.Consumer consumer)
|
String |
toString()
|
com.rabbitmq.client.AMQP.Tx.CommitOk |
txCommit()
|
com.rabbitmq.client.AMQP.Tx.RollbackOk |
txRollback()
|
com.rabbitmq.client.AMQP.Tx.SelectOk |
txSelect()
|
boolean |
waitForConfirms()
|
boolean |
waitForConfirms(long timeout)
|
void |
waitForConfirmsOrDie()
|
void |
waitForConfirmsOrDie(long timeout)
|
PublisherCallbackChannelImpl
public PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate)
addShutdownListener
public void addShutdownListener(com.rabbitmq.client.ShutdownListener listener)
- Specified by:
addShutdownListener in interface com.rabbitmq.client.ShutdownNotifier
removeShutdownListener
public void removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)
- Specified by:
removeShutdownListener in interface com.rabbitmq.client.ShutdownNotifier
getCloseReason
public com.rabbitmq.client.ShutdownSignalException getCloseReason()
- Specified by:
getCloseReason in interface com.rabbitmq.client.ShutdownNotifier
notifyListeners
public void notifyListeners()
- Specified by:
notifyListeners in interface com.rabbitmq.client.ShutdownNotifier
isOpen
public boolean isOpen()
- Specified by:
isOpen in interface com.rabbitmq.client.ShutdownNotifier
getChannelNumber
public int getChannelNumber()
- Specified by:
getChannelNumber in interface com.rabbitmq.client.Channel
getConnection
public com.rabbitmq.client.Connection getConnection()
- Specified by:
getConnection in interface com.rabbitmq.client.Channel
close
public void close(int closeCode,
String closeMessage)
throws IOException
- Specified by:
close in interface com.rabbitmq.client.Channel
- Throws:
IOException
flow
public com.rabbitmq.client.AMQP.Channel.FlowOk flow(boolean active)
throws IOException
- Specified by:
flow in interface com.rabbitmq.client.Channel
- Throws:
IOException
getFlow
public com.rabbitmq.client.AMQP.Channel.FlowOk getFlow()
- Specified by:
getFlow in interface com.rabbitmq.client.Channel
abort
public void abort()
throws IOException
- Specified by:
abort in interface com.rabbitmq.client.Channel
- Throws:
IOException
abort
public void abort(int closeCode,
String closeMessage)
throws IOException
- Specified by:
abort in interface com.rabbitmq.client.Channel
- Throws:
IOException
addFlowListener
public void addFlowListener(com.rabbitmq.client.FlowListener listener)
- Specified by:
addFlowListener in interface com.rabbitmq.client.Channel
removeFlowListener
public boolean removeFlowListener(com.rabbitmq.client.FlowListener listener)
- Specified by:
removeFlowListener in interface com.rabbitmq.client.Channel
clearFlowListeners
public void clearFlowListeners()
- Specified by:
clearFlowListeners in interface com.rabbitmq.client.Channel
getDefaultConsumer
public com.rabbitmq.client.Consumer getDefaultConsumer()
- Specified by:
getDefaultConsumer in interface com.rabbitmq.client.Channel
setDefaultConsumer
public void setDefaultConsumer(com.rabbitmq.client.Consumer consumer)
- Specified by:
setDefaultConsumer in interface com.rabbitmq.client.Channel
basicQos
public void basicQos(int prefetchSize,
int prefetchCount,
boolean global)
throws IOException
- Specified by:
basicQos in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicQos
public void basicQos(int prefetchCount)
throws IOException
- Specified by:
basicQos in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicPublish
public void basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
throws IOException
- Specified by:
basicPublish in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicPublish
public void basicPublish(String exchange,
String routingKey,
boolean mandatory,
boolean immediate,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
throws IOException
- Specified by:
basicPublish in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicPublish
public void basicPublish(String exchange,
String routingKey,
boolean mandatory,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body)
throws IOException
- Specified by:
basicPublish in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDeclare
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange,
String type)
throws IOException
- Specified by:
exchangeDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDeclare
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange,
String type,
boolean durable)
throws IOException
- Specified by:
exchangeDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDeclare
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
Map<String,Object> arguments)
throws IOException
- Specified by:
exchangeDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDeclare
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
boolean internal,
Map<String,Object> arguments)
throws IOException
- Specified by:
exchangeDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDeclarePassive
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive(String name)
throws IOException
- Specified by:
exchangeDeclarePassive in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDelete
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(String exchange,
boolean ifUnused)
throws IOException
- Specified by:
exchangeDelete in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeDelete
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(String exchange)
throws IOException
- Specified by:
exchangeDelete in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeBind
public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind(String destination,
String source,
String routingKey)
throws IOException
- Specified by:
exchangeBind in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeBind
public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
throws IOException
- Specified by:
exchangeBind in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeUnbind
public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind(String destination,
String source,
String routingKey)
throws IOException
- Specified by:
exchangeUnbind in interface com.rabbitmq.client.Channel
- Throws:
IOException
exchangeUnbind
public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
throws IOException
- Specified by:
exchangeUnbind in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueDeclare
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare()
throws IOException
- Specified by:
queueDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueDeclare
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Map<String,Object> arguments)
throws IOException
- Specified by:
queueDeclare in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueDeclarePassive
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive(String queue)
throws IOException
- Specified by:
queueDeclarePassive in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueDelete
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue)
throws IOException
- Specified by:
queueDelete in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueDelete
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue,
boolean ifUnused,
boolean ifEmpty)
throws IOException
- Specified by:
queueDelete in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueBind
public com.rabbitmq.client.AMQP.Queue.BindOk queueBind(String queue,
String exchange,
String routingKey)
throws IOException
- Specified by:
queueBind in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueBind
public com.rabbitmq.client.AMQP.Queue.BindOk queueBind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
throws IOException
- Specified by:
queueBind in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueUnbind
public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind(String queue,
String exchange,
String routingKey)
throws IOException
- Specified by:
queueUnbind in interface com.rabbitmq.client.Channel
- Throws:
IOException
queueUnbind
public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
throws IOException
- Specified by:
queueUnbind in interface com.rabbitmq.client.Channel
- Throws:
IOException
queuePurge
public com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge(String queue)
throws IOException
- Specified by:
queuePurge in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicGet
public com.rabbitmq.client.GetResponse basicGet(String queue,
boolean autoAck)
throws IOException
- Specified by:
basicGet in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicAck
public void basicAck(long deliveryTag,
boolean multiple)
throws IOException
- Specified by:
basicAck in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicNack
public void basicNack(long deliveryTag,
boolean multiple,
boolean requeue)
throws IOException
- Specified by:
basicNack in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicReject
public void basicReject(long deliveryTag,
boolean requeue)
throws IOException
- Specified by:
basicReject in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicConsume
public String basicConsume(String queue,
com.rabbitmq.client.Consumer callback)
throws IOException
- Specified by:
basicConsume in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicConsume
public String basicConsume(String queue,
boolean autoAck,
com.rabbitmq.client.Consumer callback)
throws IOException
- Specified by:
basicConsume in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicConsume
public String basicConsume(String queue,
boolean autoAck,
String consumerTag,
com.rabbitmq.client.Consumer callback)
throws IOException
- Specified by:
basicConsume in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicConsume
public String basicConsume(String queue,
boolean autoAck,
String consumerTag,
boolean noLocal,
boolean exclusive,
Map<String,Object> arguments,
com.rabbitmq.client.Consumer callback)
throws IOException
- Specified by:
basicConsume in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicCancel
public void basicCancel(String consumerTag)
throws IOException
- Specified by:
basicCancel in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicRecover
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover()
throws IOException
- Specified by:
basicRecover in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicRecover
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover(boolean requeue)
throws IOException
- Specified by:
basicRecover in interface com.rabbitmq.client.Channel
- Throws:
IOException
basicRecoverAsync
public void basicRecoverAsync(boolean requeue)
throws IOException
- Specified by:
basicRecoverAsync in interface com.rabbitmq.client.Channel
- Throws:
IOException
txSelect
public com.rabbitmq.client.AMQP.Tx.SelectOk txSelect()
throws IOException
- Specified by:
txSelect in interface com.rabbitmq.client.Channel
- Throws:
IOException
txCommit
public com.rabbitmq.client.AMQP.Tx.CommitOk txCommit()
throws IOException
- Specified by:
txCommit in interface com.rabbitmq.client.Channel
- Throws:
IOException
txRollback
public com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback()
throws IOException
- Specified by:
txRollback in interface com.rabbitmq.client.Channel
- Throws:
IOException
confirmSelect
public com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect()
throws IOException
- Specified by:
confirmSelect in interface com.rabbitmq.client.Channel
- Throws:
IOException
getNextPublishSeqNo
public long getNextPublishSeqNo()
- Specified by:
getNextPublishSeqNo in interface com.rabbitmq.client.Channel
waitForConfirms
public boolean waitForConfirms()
throws InterruptedException
- Specified by:
waitForConfirms in interface com.rabbitmq.client.Channel
- Throws:
InterruptedException
waitForConfirms
public boolean waitForConfirms(long timeout)
throws InterruptedException,
TimeoutException
- Specified by:
waitForConfirms in interface com.rabbitmq.client.Channel
- Throws:
InterruptedException
TimeoutException
waitForConfirmsOrDie
public void waitForConfirmsOrDie()
throws IOException,
InterruptedException
- Specified by:
waitForConfirmsOrDie in interface com.rabbitmq.client.Channel
- Throws:
IOException
InterruptedException
waitForConfirmsOrDie
public void waitForConfirmsOrDie(long timeout)
throws IOException,
InterruptedException,
TimeoutException
- Specified by:
waitForConfirmsOrDie in interface com.rabbitmq.client.Channel
- Throws:
IOException
InterruptedException
TimeoutException
asyncRpc
public void asyncRpc(com.rabbitmq.client.Method method)
throws IOException
- Specified by:
asyncRpc in interface com.rabbitmq.client.Channel
- Throws:
IOException
rpc
public com.rabbitmq.client.Command rpc(com.rabbitmq.client.Method method)
throws IOException
- Specified by:
rpc in interface com.rabbitmq.client.Channel
- Throws:
IOException
addConfirmListener
public void addConfirmListener(com.rabbitmq.client.ConfirmListener listener)
- Specified by:
addConfirmListener in interface com.rabbitmq.client.Channel
removeConfirmListener
public boolean removeConfirmListener(com.rabbitmq.client.ConfirmListener listener)
- Specified by:
removeConfirmListener in interface com.rabbitmq.client.Channel
clearConfirmListeners
public void clearConfirmListeners()
- Specified by:
clearConfirmListeners in interface com.rabbitmq.client.Channel
addReturnListener
public void addReturnListener(com.rabbitmq.client.ReturnListener listener)
- Specified by:
addReturnListener in interface com.rabbitmq.client.Channel
removeReturnListener
public boolean removeReturnListener(com.rabbitmq.client.ReturnListener listener)
- Specified by:
removeReturnListener in interface com.rabbitmq.client.Channel
clearReturnListeners
public void clearReturnListeners()
- Specified by:
clearReturnListeners in interface com.rabbitmq.client.Channel
close
public void close()
throws IOException
- Specified by:
close in interface com.rabbitmq.client.Channel
- Throws:
IOException
addListener
public SortedMap<Long,PendingConfirm> addListener(PublisherCallbackChannel.Listener listener)
- Description copied from interface:
PublisherCallbackChannel
- 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.
The client must NOT modify the contents of
this array, and must synchronize on it when
iterating over its collections.
- Specified by:
addListener in interface PublisherCallbackChannel
- Parameters:
listener - The Listener.
- Returns:
- A reference to pending confirms for the listener
removeListener
public boolean removeListener(PublisherCallbackChannel.Listener listener)
- Description copied from interface:
PublisherCallbackChannel
- Gets a reference to the current listener, or null.
- Specified by:
removeListener in interface PublisherCallbackChannel
- Returns:
- the Listener.
handleAck
public void handleAck(long seq,
boolean multiple)
throws IOException
- Specified by:
handleAck in interface com.rabbitmq.client.ConfirmListener
- Throws:
IOException
handleNack
public void handleNack(long seq,
boolean multiple)
throws IOException
- Specified by:
handleNack in interface com.rabbitmq.client.ConfirmListener
- Throws:
IOException
addPendingConfirm
public void addPendingConfirm(PublisherCallbackChannel.Listener listener,
long seq,
PendingConfirm pendingConfirm)
- Description copied from interface:
PublisherCallbackChannel
- Adds a pending confirmation to this channel's map.
- Specified by:
addPendingConfirm in interface PublisherCallbackChannel
seq - The key to the map.pendingConfirm - The PendingConfirm object.
handleReturn
public void handleReturn(int replyCode,
String replyText,
String exchange,
String routingKey,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body)
throws IOException
- Specified by:
handleReturn in interface com.rabbitmq.client.ReturnListener
- Throws:
IOException
hashCode
public int hashCode()
- Overrides:
hashCode in class Object
equals
public boolean equals(Object obj)
- Overrides:
equals in class Object
toString
public String toString()
- Overrides:
toString in class Object