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, Christian Tzolov
-
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
ConstructorDescriptionPublisherCallbackChannelImpl
(com.rabbitmq.client.Channel delegate, ExecutorService executor) Create aPublisherCallbackChannelImpl
instance based on the provided delegate and executor. -
Method Summary
Modifier and TypeMethodDescriptionvoid
abort()
void
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) basicConsume
(String queue, boolean autoAck, com.rabbitmq.client.Consumer callback) basicConsume
(String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback) Added to the 5.0.x client.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.basicConsume
(String queue, boolean autoAck, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback) Added to the 5.0.x client.basicConsume
(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String, Object> arguments, com.rabbitmq.client.Consumer callback) 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.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.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.basicConsume
(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.Consumer callback) basicConsume
(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback) Added to the 5.0.x client.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.basicConsume
(String queue, boolean autoAck, String consumerTag, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback) Added to the 5.0.x client.basicConsume
(String queue, boolean autoAck, Map<String, Object> arguments, com.rabbitmq.client.Consumer callback) Added to the 3.3.x client.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.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.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.basicConsume
(String queue, com.rabbitmq.client.Consumer callback) basicConsume
(String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.CancelCallback cancelCallback) Added to the 5.0.x client.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.basicConsume
(String queue, com.rabbitmq.client.DeliverCallback deliverCallback, com.rabbitmq.client.ConsumerShutdownSignalCallback shutdownSignalCallback) Added to the 5.0.x client.com.rabbitmq.client.GetResponse
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
com.rabbitmq.client.AMQP.Basic.RecoverOk
basicRecover
(boolean requeue) void
basicReject
(long deliveryTag, boolean requeue) void
void
void
close()
void
com.rabbitmq.client.AMQP.Confirm.SelectOk
long
consumerCount
(String queue) boolean
com.rabbitmq.client.AMQP.Exchange.BindOk
exchangeBind
(String destination, String source, String routingKey) com.rabbitmq.client.AMQP.Exchange.BindOk
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
void
exchangeUnbindNoWait
(String destination, String source, String routingKey, Map<String, Object> arguments) expire
(PublisherCallbackChannel.Listener listener, long cutoffTime) Expire (remove) anyPendingConfirm
s created before cutoffTime for the supplied listener and return them to the caller.factory()
int
com.rabbitmq.client.ShutdownSignalException
com.rabbitmq.client.Connection
com.rabbitmq.client.Consumer
com.rabbitmq.client.Channel
Use this to invoke methods on the underlying rabbit clientChannel
that are not supported by this implementation.long
int
Get the total pending confirms count.int
Get thePendingConfirm
s 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
com.rabbitmq.client.AMQP.Queue.BindOk
com.rabbitmq.client.AMQP.Queue.BindOk
void
com.rabbitmq.client.AMQP.Queue.DeclareOk
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
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) toString()
com.rabbitmq.client.AMQP.Tx.CommitOk
txCommit()
com.rabbitmq.client.AMQP.Tx.RollbackOk
com.rabbitmq.client.AMQP.Tx.SelectOk
txSelect()
boolean
boolean
waitForConfirms
(long timeout) void
void
waitForConfirmsOrDie
(long timeout)
-
Constructor Details
-
PublisherCallbackChannelImpl
Create aPublisherCallbackChannelImpl
instance based on the provided delegate and executor.- Parameters:
delegate
- the delegate channel.executor
- the executor.
-
-
Method Details
-
setAfterAckCallback
Description copied from interface:PublisherCallbackChannel
Set a callback to be invoked after the ack/nack has been handled.- Specified by:
setAfterAckCallback
in interfacePublisherCallbackChannel
- Parameters:
callback
- the callback.
-
addShutdownListener
public void addShutdownListener(com.rabbitmq.client.ShutdownListener listener) - Specified by:
addShutdownListener
in interfacecom.rabbitmq.client.ShutdownNotifier
-
removeShutdownListener
public void removeShutdownListener(com.rabbitmq.client.ShutdownListener listener) - Specified by:
removeShutdownListener
in interfacecom.rabbitmq.client.ShutdownNotifier
-
getCloseReason
public com.rabbitmq.client.ShutdownSignalException getCloseReason()- Specified by:
getCloseReason
in interfacecom.rabbitmq.client.ShutdownNotifier
-
notifyListeners
public void notifyListeners()- Specified by:
notifyListeners
in interfacecom.rabbitmq.client.ShutdownNotifier
-
isOpen
public boolean isOpen()- Specified by:
isOpen
in interfacecom.rabbitmq.client.ShutdownNotifier
-
getChannelNumber
public int getChannelNumber()- Specified by:
getChannelNumber
in interfacecom.rabbitmq.client.Channel
-
getConnection
public com.rabbitmq.client.Connection getConnection()- Specified by:
getConnection
in interfacecom.rabbitmq.client.Channel
-
close
- Specified by:
close
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
TimeoutException
-
abort
- Specified by:
abort
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
abort
- Specified by:
abort
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
getDefaultConsumer
public com.rabbitmq.client.Consumer getDefaultConsumer()- Specified by:
getDefaultConsumer
in interfacecom.rabbitmq.client.Channel
-
setDefaultConsumer
public void setDefaultConsumer(com.rabbitmq.client.Consumer consumer) - Specified by:
setDefaultConsumer
in interfacecom.rabbitmq.client.Channel
-
basicQos
- Specified by:
basicQos
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicQos
Added to the 3.3.x client.- Specified by:
basicQos
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
- Since:
- 1.3.3
-
basicQos
- Specified by:
basicQos
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
exchangeDeclare
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, String type) throws IOException - Specified by:
exchangeDeclare
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
exchangeDeclarePassive
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive(String name) throws IOException - Specified by:
exchangeDeclarePassive
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
exchangeDelete
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused) throws IOException - Specified by:
exchangeDelete
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
exchangeDelete
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(String exchange) throws IOException - Specified by:
exchangeDelete
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
queueDeclare
- Specified by:
queueDeclare
in interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
queueDeclarePassive
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive(String queue) throws IOException - Specified by:
queueDeclarePassive
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
queueDelete
- Specified by:
queueDelete
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
queuePurge
- Specified by:
queuePurge
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicGet
- Specified by:
basicGet
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicAck
- Specified by:
basicAck
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicNack
- Specified by:
basicNack
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicReject
- Specified by:
basicReject
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicConsume
- Specified by:
basicConsume
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.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 IOExceptionAdded to the 3.3.x client.- Specified by:
basicConsume
in interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.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 interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.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 IOExceptionAdded to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
- Since:
- 2.0
-
basicCancel
- Specified by:
basicCancel
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicRecover
- Specified by:
basicRecover
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicRecover
- Specified by:
basicRecover
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txSelect
- Specified by:
txSelect
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txCommit
- Specified by:
txCommit
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txRollback
- Specified by:
txRollback
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
confirmSelect
- Specified by:
confirmSelect
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
getNextPublishSeqNo
public long getNextPublishSeqNo()- Specified by:
getNextPublishSeqNo
in interfacecom.rabbitmq.client.Channel
-
waitForConfirms
- Specified by:
waitForConfirms
in interfacecom.rabbitmq.client.Channel
- Throws:
InterruptedException
-
waitForConfirms
- Specified by:
waitForConfirms
in interfacecom.rabbitmq.client.Channel
- Throws:
InterruptedException
TimeoutException
-
waitForConfirmsOrDie
- Specified by:
waitForConfirmsOrDie
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
InterruptedException
-
waitForConfirmsOrDie
public void waitForConfirmsOrDie(long timeout) throws IOException, InterruptedException, TimeoutException - Specified by:
waitForConfirmsOrDie
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
InterruptedException
TimeoutException
-
asyncRpc
- Specified by:
asyncRpc
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
rpc
- Specified by:
rpc
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
addConfirmListener
public void addConfirmListener(com.rabbitmq.client.ConfirmListener listener) - Specified by:
addConfirmListener
in interfacecom.rabbitmq.client.Channel
-
addConfirmListener
public com.rabbitmq.client.ConfirmListener addConfirmListener(com.rabbitmq.client.ConfirmCallback ackCallback, com.rabbitmq.client.ConfirmCallback nackCallback) - Specified by:
addConfirmListener
in interfacecom.rabbitmq.client.Channel
-
removeConfirmListener
public boolean removeConfirmListener(com.rabbitmq.client.ConfirmListener listener) - Specified by:
removeConfirmListener
in interfacecom.rabbitmq.client.Channel
-
clearConfirmListeners
public void clearConfirmListeners()- Specified by:
clearConfirmListeners
in interfacecom.rabbitmq.client.Channel
-
addReturnListener
public void addReturnListener(com.rabbitmq.client.ReturnListener listener) - Specified by:
addReturnListener
in interfacecom.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 interfacecom.rabbitmq.client.Channel
- Since:
- 2.0
-
removeReturnListener
public boolean removeReturnListener(com.rabbitmq.client.ReturnListener listener) - Specified by:
removeReturnListener
in interfacecom.rabbitmq.client.Channel
-
clearReturnListeners
public void clearReturnListeners()- Specified by:
clearReturnListeners
in interfacecom.rabbitmq.client.Channel
-
exchangeBindNoWait
public void exchangeBindNoWait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException- Specified by:
exchangeBindNoWait
in interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
exchangeDeleteNoWait
- Specified by:
exchangeDeleteNoWait
in interfacecom.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 interfacecom.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 interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
queueDeleteNoWait
- Specified by:
queueDeleteNoWait
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
consumerCount
- Specified by:
consumerCount
in interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
- Since:
- 2.0
-
messageCount
- Specified by:
messageCount
in interfacecom.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 clientChannel
that are not supported by this implementation.- Specified by:
getDelegate
in interfacePublisherCallbackChannel
- Returns:
- The underlying rabbit client
Channel
.
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
TimeoutException
-
getPendingConfirmsCount
Description copied from interface:PublisherCallbackChannel
Get thePendingConfirm
s count.- Specified by:
getPendingConfirmsCount
in interfacePublisherCallbackChannel
- 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 interfacePublisherCallbackChannel
- Returns:
- the count.
-
addListener
Add the listener and return the internal map of pending confirmations for that listener.- Specified by:
addListener
in interfacePublisherCallbackChannel
- Parameters:
listener
- the listener.
-
expire
public Collection<PendingConfirm> expire(PublisherCallbackChannel.Listener listener, long cutoffTime) Description copied from interface:PublisherCallbackChannel
Expire (remove) anyPendingConfirm
s created before cutoffTime for the supplied listener and return them to the caller.- Specified by:
expire
in interfacePublisherCallbackChannel
- 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 interfacecom.rabbitmq.client.ConfirmListener
-
handleNack
public void handleNack(long seq, boolean multiple) - Specified by:
handleNack
in interfacecom.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 interfacePublisherCallbackChannel
- 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 interfacecom.rabbitmq.client.ReturnCallback
-
shutdownCompleted
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause) - Specified by:
shutdownCompleted
in interfacecom.rabbitmq.client.ShutdownListener
-
hashCode
public int hashCode() -
equals
-
toString
-
factory
-