PublisherCallbackChannelImpl (Spring AMQP 2.2.11.RELEASE API)

java.lang.Object
- org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

All Implemented Interfaces:

com.rabbitmq.client.Channel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener, com.rabbitmq.client.ShutdownListener, com.rabbitmq.client.ShutdownNotifier, AutoCloseable, EventListener, PublisherCallbackChannel
```
public class PublisherCallbackChannelImpl
extends Object
implements PublisherCallbackChannel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener, com.rabbitmq.client.ShutdownListener
```
Channel wrapper to allow a single listener able to handle confirms from multiple channels.

Since:

1.0.1

Author:

Gary Russell, Arnaud Cogoluègnes, Artem Bilan

Nested Class Summary
- Nested classes/interfaces inherited from interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
  PublisherCallbackChannel.Listener

Field Summary
- Fields inherited from interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
  RETURN_LISTENER_CORRELATION_KEY, RETURNED_MESSAGE_CORRELATION_KEY

Constructor Summary

Constructors
Constructor and Description
`PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate, ExecutorService executor)` Create a `PublisherCallbackChannelImpl` instance based on the provided delegate and executor.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`abort()`
`void`	`abort(int closeCode, String closeMessage)`
`com.rabbitmq.client.ConfirmListener`	`addConfirmListener(com.rabbitmq.client.ConfirmCallback ackCallback, com.rabbitmq.client.ConfirmCallback nackCallback)`
`void`	`addConfirmListener(com.rabbitmq.client.ConfirmListener listener)`
`void`	`addListener(PublisherCallbackChannel.Listener listener)` Add the listener and return the internal map of pending confirmations for that listener.
`void`	`addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)` Adds a pending confirmation to this channel's map.
`com.rabbitmq.client.ReturnListener`	`addReturnListener(com.rabbitmq.client.ReturnCallback returnCallback)` Added to the 5.0.x client.
`void`	`addReturnListener(com.rabbitmq.client.ReturnListener listener)`
`void`	`addShutdownListener(com.rabbitmq.client.ShutdownListener listener)`
`CompletableFuture<com.rabbitmq.client.Command>`	`asyncCompletableRpc(com.rabbitmq.client.Method method)` Added to the 5.0.x client.
`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, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, com.rabbitmq.client.Consumer callback)` Added to the 3.3.x client.
`String`	`basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`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, boolean noLocal, boolean exclusive, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.Consumer callback)`
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, com.rabbitmq.client.Consumer callback)`
`String`	`basicConsume(String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`String`	`basicConsume(String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)` Added to the 5.0.x client.
`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 prefetchCount, boolean global)` Added to the 3.3.x client.
`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`	`basicReject(long deliveryTag, boolean requeue)`
`void`	`clearConfirmListeners()`
`void`	`clearReturnListeners()`
`void`	`close()`
`void`	`close(int closeCode, String closeMessage)`
`com.rabbitmq.client.AMQP.Confirm.SelectOk`	`confirmSelect()`
`long`	`consumerCount(String queue)`
`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)`
`void`	`exchangeBindNoWait(String destination, String source, String routingKey, Map<String,Object> arguments)`
`com.rabbitmq.client.AMQP.Exchange.DeclareOk`	`exchangeDeclare(String exchange, com.rabbitmq.client.BuiltinExchangeType type)`
`com.rabbitmq.client.AMQP.Exchange.DeclareOk`	`exchangeDeclare(String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable)`
`com.rabbitmq.client.AMQP.Exchange.DeclareOk`	`exchangeDeclare(String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)`
`com.rabbitmq.client.AMQP.Exchange.DeclareOk`	`exchangeDeclare(String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, 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)`
`void`	`exchangeDeclareNoWait(String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)`
`void`	`exchangeDeclareNoWait(String exchange, String type, boolean durable, boolean autoDelete, boolean internal, 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)`
`void`	`exchangeDeleteNoWait(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)`
`void`	`exchangeUnbindNoWait(String destination, String source, String routingKey, Map<String,Object> arguments)`
`Collection<PendingConfirm>`	`expire(PublisherCallbackChannel.Listener listener, long cutoffTime)` Expire (remove) any `PendingConfirm`s created before cutoffTime for the supplied listener and return them to the caller.
`static PublisherCallbackChannelFactory`	`factory()`
`int`	`getChannelNumber()`
`com.rabbitmq.client.ShutdownSignalException`	`getCloseReason()`
`com.rabbitmq.client.Connection`	`getConnection()`
`com.rabbitmq.client.Consumer`	`getDefaultConsumer()`
`com.rabbitmq.client.Channel`	`getDelegate()` Use this to invoke methods on the underlying rabbit client `Channel` that are not supported by this implementation.
`long`	`getNextPublishSeqNo()`
`int`	`getPendingConfirmsCount()` Get the total pending confirms count.
`int`	`getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)` Get the `PendingConfirm`s count.
`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()`
`long`	`messageCount(String queue)`
`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)`
`void`	`queueBindNoWait(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)`
`void`	`queueDeclareNoWait(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)`
`void`	`queueDeleteNoWait(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`	`removeReturnListener(com.rabbitmq.client.ReturnListener listener)`
`void`	`removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)`
`com.rabbitmq.client.Command`	`rpc(com.rabbitmq.client.Method method)`
`void`	`setAfterAckCallback(Consumer<com.rabbitmq.client.Channel> callback)` Set a callback to be invoked after the ack/nack has been handled.
`void`	`setDefaultConsumer(com.rabbitmq.client.Consumer consumer)`
`void`	`shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)`
`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)`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail
- PublisherCallbackChannelImpl
```
public PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate,
                                    ExecutorService executor)
```
  Create a PublisherCallbackChannelImpl instance based on the provided delegate and executor.
  
  Parameters:
  
  delegate - the delegate channel.
  
  executor - the executor.

Method Detail

setAfterAckCallback
```
public void setAfterAckCallback(Consumer<com.rabbitmq.client.Channel> callback)
```
Description copied from interface: PublisherCallbackChannel

Set a callback to be invoked after the ack/nack has been handled.

Specified by:

setAfterAckCallback in interface PublisherCallbackChannel

Parameters:

callback - the callback.

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,
                  TimeoutException

Specified by:: close in interface com.rabbitmq.client.Channel
Throws:: IOException; TimeoutException

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

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,
                     boolean global)
              throws IOException
```
Added to the 3.3.x client.

Specified by:

basicQos in interface com.rabbitmq.client.Channel

Throws:

IOException

Since:

1.3.3

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,
                                                                   com.rabbitmq.client.BuiltinExchangeType 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,
                                                                   com.rabbitmq.client.BuiltinExchangeType 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,
                                                                   com.rabbitmq.client.BuiltinExchangeType 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

exchangeDeclare

public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange,
                                                                   com.rabbitmq.client.BuiltinExchangeType 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,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

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,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

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,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           String consumerTag,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           String consumerTag,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.Consumer callback)
                    throws IOException

Added to the 3.3.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 1.3.3

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

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

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           String consumerTag,
                           boolean noLocal,
                           boolean exclusive,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           String consumerTag,
                           boolean noLocal,
                           boolean exclusive,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

basicConsume

public String basicConsume(String queue,
                           boolean autoAck,
                           String consumerTag,
                           boolean noLocal,
                           boolean exclusive,
                           Map<String,Object> arguments,
                           com.rabbitmq.client.DeliverCallback deliverCallback,
                           com.rabbitmq.client.CancelCallback cancelCallback,
                           com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback)
                    throws IOException

Added to the 5.0.x client.

Specified by:: basicConsume in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

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

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

addConfirmListener

public com.rabbitmq.client.ConfirmListener addConfirmListener(com.rabbitmq.client.ConfirmCallback ackCallback,
                                                              com.rabbitmq.client.ConfirmCallback nackCallback)

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

addReturnListener
```
public com.rabbitmq.client.ReturnListener addReturnListener(com.rabbitmq.client.ReturnCallback returnCallback)
```
Added to the 5.0.x client.

Specified by:

addReturnListener in interface com.rabbitmq.client.Channel

Since:

2.0

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

exchangeBindNoWait

public void exchangeBindNoWait(String destination,
                               String source,
                               String routingKey,
                               Map<String,Object> arguments)
                        throws IOException

Specified by:: exchangeBindNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

exchangeDeclareNoWait

public void exchangeDeclareNoWait(String exchange,
                                  String type,
                                  boolean durable,
                                  boolean autoDelete,
                                  boolean internal,
                                  Map<String,Object> arguments)
                           throws IOException

Specified by:: exchangeDeclareNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

exchangeDeclareNoWait

public void exchangeDeclareNoWait(String exchange,
                                  com.rabbitmq.client.BuiltinExchangeType type,
                                  boolean durable,
                                  boolean autoDelete,
                                  boolean internal,
                                  Map<String,Object> arguments)
                           throws IOException

Specified by:: exchangeDeclareNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

exchangeDeleteNoWait

public void exchangeDeleteNoWait(String exchange,
                                 boolean ifUnused)
                          throws IOException

Specified by:: exchangeDeleteNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

exchangeUnbindNoWait

public void exchangeUnbindNoWait(String destination,
                                 String source,
                                 String routingKey,
                                 Map<String,Object> arguments)
                          throws IOException

Specified by:: exchangeUnbindNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

queueBindNoWait

public void queueBindNoWait(String queue,
                            String exchange,
                            String routingKey,
                            Map<String,Object> arguments)
                     throws IOException

Specified by:: queueBindNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

queueDeclareNoWait

public void queueDeclareNoWait(String queue,
                               boolean durable,
                               boolean exclusive,
                               boolean autoDelete,
                               Map<String,Object> arguments)
                        throws IOException

Specified by:: queueDeclareNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

queueDeleteNoWait

public void queueDeleteNoWait(String queue,
                              boolean ifUnused,
                              boolean ifEmpty)
                       throws IOException

Specified by:: queueDeleteNoWait in interface com.rabbitmq.client.Channel
Throws:: IOException

consumerCount
```
public long consumerCount(String queue)
                   throws IOException
```
Specified by:

consumerCount in interface com.rabbitmq.client.Channel

Throws:

IOException

asyncCompletableRpc

public CompletableFuture<com.rabbitmq.client.Command> asyncCompletableRpc(com.rabbitmq.client.Method method)
                                                                   throws IOException

Added to the 5.0.x client.

Specified by:: asyncCompletableRpc in interface com.rabbitmq.client.Channel
Throws:: IOException
Since:: 2.0

messageCount
```
public long messageCount(String queue)
                  throws IOException
```
Specified by:

messageCount in interface com.rabbitmq.client.Channel

Throws:

IOException

getDelegate
```
public com.rabbitmq.client.Channel getDelegate()
```
Description copied from interface: PublisherCallbackChannel

Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.

Specified by:

getDelegate in interface PublisherCallbackChannel

Returns:

The underlying rabbit client Channel.

close
```
public void close()
           throws IOException,
                  TimeoutException
```
Specified by:

close in interface com.rabbitmq.client.Channel

Specified by:

close in interface AutoCloseable

Throws:

IOException

TimeoutException

getPendingConfirmsCount
```
public int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
```
Description copied from interface: PublisherCallbackChannel

Get the PendingConfirms count.

Specified by:

getPendingConfirmsCount in interface PublisherCallbackChannel

Parameters:

listener - the listener.

Returns:

Count of the pending confirms.

getPendingConfirmsCount
```
public int getPendingConfirmsCount()
```
Description copied from interface: PublisherCallbackChannel

Get the total pending confirms count.

Specified by:

getPendingConfirmsCount in interface PublisherCallbackChannel

Returns:

the count.

addListener
```
public void addListener(PublisherCallbackChannel.Listener listener)
```
Add the listener and return the internal map of pending confirmations for that listener.

Specified by:

addListener in interface PublisherCallbackChannel

Parameters:

listener - the listener.

expire
```
public Collection<PendingConfirm> expire(PublisherCallbackChannel.Listener listener,
                                         long cutoffTime)
```
Description copied from interface: PublisherCallbackChannel

Expire (remove) any PendingConfirms created before cutoffTime for the supplied listener and return them to the caller.

Specified by:

expire in interface PublisherCallbackChannel

Parameters:

listener - the listener.

cutoffTime - the time before which expired messages were created.

Returns:

the list of expired confirms.

handleAck
```
public void handleAck(long seq,
                      boolean multiple)
```
Specified by:

handleAck in interface com.rabbitmq.client.ConfirmListener

handleNack
```
public void handleNack(long seq,
                       boolean multiple)
```
Specified by:

handleNack in interface com.rabbitmq.client.ConfirmListener

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

Parameters:

listener - The listener.

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)

Specified by:: handleReturn in interface com.rabbitmq.client.ReturnListener

shutdownCompleted
```
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)
```
Specified by:

shutdownCompleted in interface com.rabbitmq.client.ShutdownListener

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

factory

public static PublisherCallbackChannelFactory factory()

Class PublisherCallbackChannelImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel

Field Summary

Fields inherited from interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

PublisherCallbackChannelImpl

Method Detail

setAfterAckCallback

addShutdownListener

removeShutdownListener

getCloseReason

notifyListeners

isOpen

getChannelNumber

getConnection

close

abort

abort

getDefaultConsumer

setDefaultConsumer

basicQos

basicQos

basicQos

basicPublish

basicPublish

basicPublish

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclare

exchangeDeclarePassive

exchangeDelete

exchangeDelete

exchangeBind

exchangeBind

exchangeUnbind

exchangeUnbind

queueDeclare

queueDeclare

queueDeclarePassive

queueDelete

queueDelete

queueBind

queueBind

queueUnbind

queueUnbind

queuePurge

basicGet

basicAck

basicNack

basicReject

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicConsume

basicCancel