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 aPublisherCallbackChannelImpl
instance based on the provided delegate and executor.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods 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) anyPendingConfirm
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 clientChannel
that are not supported by this implementation.long
getNextPublishSeqNo()
int
getPendingConfirmsCount()
Get the total pending confirms count.int
getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
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
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)
-
-
-
Constructor Detail
-
PublisherCallbackChannelImpl
public PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate, ExecutorService executor)
Create aPublisherCallbackChannelImpl
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 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
public void close(int closeCode, String closeMessage) throws IOException, TimeoutException
- Specified by:
close
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
TimeoutException
-
abort
public void abort() throws IOException
- Specified by:
abort
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
abort
public void abort(int closeCode, String closeMessage) throws IOException
- 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
public void basicQos(int prefetchSize, int prefetchCount, boolean global) throws IOException
- Specified by:
basicQos
in interfacecom.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 interfacecom.rabbitmq.client.Channel
- Throws:
IOException
- Since:
- 1.3.3
-
basicQos
public void basicQos(int prefetchCount) throws IOException
- 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
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare() throws IOException
- 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
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(String queue) throws IOException
- 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
public com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge(String queue) throws IOException
- Specified by:
queuePurge
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicGet
public com.rabbitmq.client.GetResponse basicGet(String queue, boolean autoAck) throws IOException
- Specified by:
basicGet
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicAck
public void basicAck(long deliveryTag, boolean multiple) throws IOException
- Specified by:
basicAck
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicNack
public void basicNack(long deliveryTag, boolean multiple, boolean requeue) throws IOException
- Specified by:
basicNack
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicReject
public void basicReject(long deliveryTag, boolean requeue) throws IOException
- Specified by:
basicReject
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicConsume
public String basicConsume(String queue, com.rabbitmq.client.Consumer callback) throws IOException
- 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 IOException
Added 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 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.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, 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 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 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, 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 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 IOException
Added to the 5.0.x client.- Specified by:
basicConsume
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
- Since:
- 2.0
-
basicCancel
public void basicCancel(String consumerTag) throws IOException
- Specified by:
basicCancel
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicRecover
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover() throws IOException
- Specified by:
basicRecover
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
basicRecover
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover(boolean requeue) throws IOException
- Specified by:
basicRecover
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txSelect
public com.rabbitmq.client.AMQP.Tx.SelectOk txSelect() throws IOException
- Specified by:
txSelect
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txCommit
public com.rabbitmq.client.AMQP.Tx.CommitOk txCommit() throws IOException
- Specified by:
txCommit
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
txRollback
public com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback() throws IOException
- Specified by:
txRollback
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
confirmSelect
public com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect() throws IOException
- Specified by:
confirmSelect
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
getNextPublishSeqNo
public long getNextPublishSeqNo()
- Specified by:
getNextPublishSeqNo
in interfacecom.rabbitmq.client.Channel
-
waitForConfirms
public boolean waitForConfirms() throws InterruptedException
- Specified by:
waitForConfirms
in interfacecom.rabbitmq.client.Channel
- Throws:
InterruptedException
-
waitForConfirms
public boolean waitForConfirms(long timeout) throws InterruptedException, TimeoutException
- Specified by:
waitForConfirms
in interfacecom.rabbitmq.client.Channel
- Throws:
InterruptedException
TimeoutException
-
waitForConfirmsOrDie
public void waitForConfirmsOrDie() throws IOException, InterruptedException
- 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
public void asyncRpc(com.rabbitmq.client.Method method) throws IOException
- Specified by:
asyncRpc
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
rpc
public com.rabbitmq.client.Command rpc(com.rabbitmq.client.Method method) throws IOException
- 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
public void exchangeDeleteNoWait(String exchange, boolean ifUnused) throws IOException
- 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
public void queueDeleteNoWait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException
- Specified by:
queueDeleteNoWait
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
-
consumerCount
public long consumerCount(String queue) throws IOException
- 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
public long messageCount(String queue) throws IOException
- 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
public void close() throws IOException, TimeoutException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfacecom.rabbitmq.client.Channel
- Throws:
IOException
TimeoutException
-
getPendingConfirmsCount
public int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
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
public void addListener(PublisherCallbackChannel.Listener listener)
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
-
factory
public static PublisherCallbackChannelFactory factory()
-
-