public class ChannelProxy extends Object implements Channel
Channel
proxy that re-open the underlying channel if necessary.
This class is used only for resource management in Sender
, so
only Channel.asyncCompletableRpc(Method)
checks whether the
underlying Channel
is closed or not, and re-open it if
necessary. All other methods are not supported.
Constructor and Description |
---|
ChannelProxy(Connection connection) |
public ChannelProxy(Connection connection) throws IOException
IOException
public int getChannelNumber()
getChannelNumber
in interface Channel
public Connection getConnection()
getConnection
in interface Channel
public void close()
close
in interface Channel
close
in interface AutoCloseable
public void close(int closeCode, String closeMessage)
public void abort(int closeCode, String closeMessage)
public void addReturnListener(ReturnListener listener)
addReturnListener
in interface Channel
public ReturnListener addReturnListener(ReturnCallback returnCallback)
addReturnListener
in interface Channel
public boolean removeReturnListener(ReturnListener listener)
removeReturnListener
in interface Channel
public void clearReturnListeners()
clearReturnListeners
in interface Channel
public void addConfirmListener(ConfirmListener listener)
addConfirmListener
in interface Channel
public ConfirmListener addConfirmListener(ConfirmCallback ackCallback, ConfirmCallback nackCallback)
addConfirmListener
in interface Channel
public boolean removeConfirmListener(ConfirmListener listener)
removeConfirmListener
in interface Channel
public void clearConfirmListeners()
clearConfirmListeners
in interface Channel
public Consumer getDefaultConsumer()
getDefaultConsumer
in interface Channel
public void setDefaultConsumer(Consumer consumer)
setDefaultConsumer
in interface Channel
public void basicQos(int prefetchSize, int prefetchCount, boolean global)
public void basicQos(int prefetchCount, boolean global)
public void basicPublish(String exchange, String routingKey, AMQP.BasicProperties props, byte[] body)
basicPublish
in interface Channel
public void basicPublish(String exchange, String routingKey, boolean mandatory, AMQP.BasicProperties props, byte[] body)
basicPublish
in interface Channel
public void basicPublish(String exchange, String routingKey, boolean mandatory, boolean immediate, AMQP.BasicProperties props, byte[] body)
basicPublish
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, String type)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, String type, boolean durable)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, Map<String,Object> arguments)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, Map<String,Object> arguments)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)
exchangeDeclare
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)
exchangeDeclare
in interface Channel
public void exchangeDeclareNoWait(String exchange, String type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)
exchangeDeclareNoWait
in interface Channel
public void exchangeDeclareNoWait(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map<String,Object> arguments)
exchangeDeclareNoWait
in interface Channel
public AMQP.Exchange.DeclareOk exchangeDeclarePassive(String name)
exchangeDeclarePassive
in interface Channel
public AMQP.Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused)
exchangeDelete
in interface Channel
public void exchangeDeleteNoWait(String exchange, boolean ifUnused)
exchangeDeleteNoWait
in interface Channel
public AMQP.Exchange.DeleteOk exchangeDelete(String exchange)
exchangeDelete
in interface Channel
public AMQP.Exchange.BindOk exchangeBind(String destination, String source, String routingKey)
exchangeBind
in interface Channel
public AMQP.Exchange.BindOk exchangeBind(String destination, String source, String routingKey, Map<String,Object> arguments)
exchangeBind
in interface Channel
public void exchangeBindNoWait(String destination, String source, String routingKey, Map<String,Object> arguments)
exchangeBindNoWait
in interface Channel
public AMQP.Exchange.UnbindOk exchangeUnbind(String destination, String source, String routingKey)
exchangeUnbind
in interface Channel
public AMQP.Exchange.UnbindOk exchangeUnbind(String destination, String source, String routingKey, Map<String,Object> arguments)
exchangeUnbind
in interface Channel
public void exchangeUnbindNoWait(String destination, String source, String routingKey, Map<String,Object> arguments)
exchangeUnbindNoWait
in interface Channel
public AMQP.Queue.DeclareOk queueDeclare()
queueDeclare
in interface Channel
public AMQP.Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String,Object> arguments)
queueDeclare
in interface Channel
public void queueDeclareNoWait(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String,Object> arguments)
queueDeclareNoWait
in interface Channel
public AMQP.Queue.DeclareOk queueDeclarePassive(String queue)
queueDeclarePassive
in interface Channel
public AMQP.Queue.DeleteOk queueDelete(String queue)
queueDelete
in interface Channel
public AMQP.Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean ifEmpty)
queueDelete
in interface Channel
public void queueDeleteNoWait(String queue, boolean ifUnused, boolean ifEmpty)
queueDeleteNoWait
in interface Channel
public AMQP.Queue.BindOk queueBind(String queue, String exchange, String routingKey)
public AMQP.Queue.BindOk queueBind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
public void queueBindNoWait(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queueBindNoWait
in interface Channel
public AMQP.Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey)
queueUnbind
in interface Channel
public AMQP.Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queueUnbind
in interface Channel
public AMQP.Queue.PurgeOk queuePurge(String queue)
queuePurge
in interface Channel
public GetResponse basicGet(String queue, boolean autoAck)
public void basicAck(long deliveryTag, boolean multiple)
public void basicNack(long deliveryTag, boolean multiple, boolean requeue)
public void basicReject(long deliveryTag, boolean requeue)
basicReject
in interface Channel
public String basicConsume(String queue, Consumer callback)
basicConsume
in interface Channel
public String basicConsume(String queue, DeliverCallback deliverCallback, CancelCallback cancelCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, Consumer callback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, DeliverCallback deliverCallback, CancelCallback cancelCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, Consumer callback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, DeliverCallback deliverCallback, CancelCallback cancelCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, Map<String,Object> arguments, DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, Consumer callback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, DeliverCallback deliverCallback, CancelCallback cancelCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, Consumer callback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, DeliverCallback deliverCallback, CancelCallback cancelCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, DeliverCallback deliverCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public String basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String,Object> arguments, DeliverCallback deliverCallback, CancelCallback cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback)
basicConsume
in interface Channel
public void basicCancel(String consumerTag)
basicCancel
in interface Channel
public AMQP.Basic.RecoverOk basicRecover()
basicRecover
in interface Channel
public AMQP.Basic.RecoverOk basicRecover(boolean requeue)
basicRecover
in interface Channel
public AMQP.Tx.SelectOk txSelect()
public AMQP.Tx.CommitOk txCommit()
public AMQP.Tx.RollbackOk txRollback()
txRollback
in interface Channel
public AMQP.Confirm.SelectOk confirmSelect()
confirmSelect
in interface Channel
public long getNextPublishSeqNo()
getNextPublishSeqNo
in interface Channel
public boolean waitForConfirms()
waitForConfirms
in interface Channel
public boolean waitForConfirms(long timeout)
waitForConfirms
in interface Channel
public void waitForConfirmsOrDie()
waitForConfirmsOrDie
in interface Channel
public void waitForConfirmsOrDie(long timeout)
waitForConfirmsOrDie
in interface Channel
public long messageCount(String queue)
messageCount
in interface Channel
public long consumerCount(String queue)
consumerCount
in interface Channel
public CompletableFuture<Command> asyncCompletableRpc(Method method) throws IOException
asyncCompletableRpc
in interface Channel
IOException
public void addShutdownListener(ShutdownListener listener)
addShutdownListener
in interface ShutdownNotifier
public void removeShutdownListener(ShutdownListener listener)
removeShutdownListener
in interface ShutdownNotifier
public ShutdownSignalException getCloseReason()
getCloseReason
in interface ShutdownNotifier
public void notifyListeners()
notifyListeners
in interface ShutdownNotifier
public boolean isOpen()
isOpen
in interface ShutdownNotifier