Package org.springframework.amqp.rabbit.connection

Class PublisherCallbackChannelImpl

java.lang.Object

org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

All Implemented Interfaces:

com.rabbitmq.client.Channel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnCallback, 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.ReturnCallback, 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	Description
PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate, ExecutorService executor)	Create a PublisherCallbackChannelImpl instance based on the provided delegate and executor.

Method Summary

Modifier and Type	Method	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, 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, 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, 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, boolean mandatory, boolean immediate, 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, 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 PendingConfirms 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 PendingConfirms count.
void	handle(com.rabbitmq.client.Return returned)
void	handleAck(long seq, boolean multiple)
void	handleNack(long seq, boolean multiple)
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 AutoCloseable

Specified by:

close in interface com.rabbitmq.client.Channel

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.

handle

public void handle(com.rabbitmq.client.Return returned)

Specified by:

handle in interface com.rabbitmq.client.ReturnCallback

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()