public class PublisherCallbackChannelImpl extends java.lang.Object implements PublisherCallbackChannel, com.rabbitmq.client.ConfirmListener, com.rabbitmq.client.ReturnListener, com.rabbitmq.client.ShutdownListener
PublisherCallbackChannel.Listener
RETURN_CORRELATION_KEY
Constructor and Description |
---|
PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
abort(int closeCode,
java.lang.String closeMessage) |
void |
addConfirmListener(com.rabbitmq.client.ConfirmListener listener) |
void |
addFlowListener(com.rabbitmq.client.FlowListener 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.
|
void |
addReturnListener(com.rabbitmq.client.ReturnListener listener) |
void |
addShutdownListener(com.rabbitmq.client.ShutdownListener listener) |
void |
asyncRpc(com.rabbitmq.client.Method method) |
void |
basicAck(long deliveryTag,
boolean multiple) |
void |
basicCancel(java.lang.String consumerTag) |
java.lang.String |
basicConsume(java.lang.String queue,
boolean autoAck,
com.rabbitmq.client.Consumer callback) |
java.lang.String |
basicConsume(java.lang.String queue,
boolean autoAck,
java.util.Map<java.lang.String,java.lang.Object> arguments,
com.rabbitmq.client.Consumer callback)
Added to the 3.3.x client
|
java.lang.String |
basicConsume(java.lang.String queue,
boolean autoAck,
java.lang.String consumerTag,
boolean noLocal,
boolean exclusive,
java.util.Map<java.lang.String,java.lang.Object> arguments,
com.rabbitmq.client.Consumer callback) |
java.lang.String |
basicConsume(java.lang.String queue,
boolean autoAck,
java.lang.String consumerTag,
com.rabbitmq.client.Consumer callback) |
java.lang.String |
basicConsume(java.lang.String queue,
com.rabbitmq.client.Consumer callback) |
com.rabbitmq.client.GetResponse |
basicGet(java.lang.String queue,
boolean autoAck) |
void |
basicNack(long deliveryTag,
boolean multiple,
boolean requeue) |
void |
basicPublish(java.lang.String exchange,
java.lang.String routingKey,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body) |
void |
basicPublish(java.lang.String exchange,
java.lang.String routingKey,
boolean mandatory,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body) |
void |
basicPublish(java.lang.String exchange,
java.lang.String routingKey,
boolean mandatory,
boolean immediate,
com.rabbitmq.client.AMQP.BasicProperties props,
byte[] body) |
void |
basicQos(int prefetchCount) |
void |
basicQos(int prefetchCount,
boolean global)
Added to the 3.3.x client
|
void |
basicQos(int prefetchSize,
int prefetchCount,
boolean global) |
com.rabbitmq.client.AMQP.Basic.RecoverOk |
basicRecover() |
com.rabbitmq.client.AMQP.Basic.RecoverOk |
basicRecover(boolean requeue) |
void |
basicReject(long deliveryTag,
boolean requeue) |
void |
clearConfirmListeners() |
void |
clearFlowListeners() |
void |
clearReturnListeners() |
void |
close() |
void |
close(int closeCode,
java.lang.String closeMessage) |
com.rabbitmq.client.AMQP.Confirm.SelectOk |
confirmSelect() |
long |
consumerCount(java.lang.String queue) |
boolean |
equals(java.lang.Object obj) |
com.rabbitmq.client.AMQP.Exchange.BindOk |
exchangeBind(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey) |
com.rabbitmq.client.AMQP.Exchange.BindOk |
exchangeBind(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
exchangeBindNoWait(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
com.rabbitmq.client.BuiltinExchangeType type) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
com.rabbitmq.client.BuiltinExchangeType type,
boolean durable) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
com.rabbitmq.client.BuiltinExchangeType type,
boolean durable,
boolean autoDelete,
boolean internal,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
com.rabbitmq.client.BuiltinExchangeType type,
boolean durable,
boolean autoDelete,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
java.lang.String type) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
java.lang.String type,
boolean durable) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
java.lang.String type,
boolean durable,
boolean autoDelete,
boolean internal,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclare(java.lang.String exchange,
java.lang.String type,
boolean durable,
boolean autoDelete,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
exchangeDeclareNoWait(java.lang.String exchange,
com.rabbitmq.client.BuiltinExchangeType type,
boolean durable,
boolean autoDelete,
boolean internal,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
exchangeDeclareNoWait(java.lang.String exchange,
java.lang.String type,
boolean durable,
boolean autoDelete,
boolean internal,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Exchange.DeclareOk |
exchangeDeclarePassive(java.lang.String name) |
com.rabbitmq.client.AMQP.Exchange.DeleteOk |
exchangeDelete(java.lang.String exchange) |
com.rabbitmq.client.AMQP.Exchange.DeleteOk |
exchangeDelete(java.lang.String exchange,
boolean ifUnused) |
void |
exchangeDeleteNoWait(java.lang.String exchange,
boolean ifUnused) |
com.rabbitmq.client.AMQP.Exchange.UnbindOk |
exchangeUnbind(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey) |
com.rabbitmq.client.AMQP.Exchange.UnbindOk |
exchangeUnbind(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
exchangeUnbindNoWait(java.lang.String destination,
java.lang.String source,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
java.util.Collection<PendingConfirm> |
expire(PublisherCallbackChannel.Listener listener,
long cutoffTime)
Expire (remove) any
PendingConfirm s created before cutoffTime for the
supplied listener and return them to the caller. |
boolean |
flowBlocked()
Deprecated.
in the 3.5.3 client
|
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() |
void |
handleAck(long seq,
boolean multiple) |
void |
handleNack(long seq,
boolean multiple) |
void |
handleReturn(int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body) |
int |
hashCode() |
boolean |
isOpen() |
long |
messageCount(java.lang.String queue) |
void |
notifyListeners() |
com.rabbitmq.client.AMQP.Queue.BindOk |
queueBind(java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey) |
com.rabbitmq.client.AMQP.Queue.BindOk |
queueBind(java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
queueBindNoWait(java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclare() |
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclare(java.lang.String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
void |
queueDeclareNoWait(java.lang.String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
com.rabbitmq.client.AMQP.Queue.DeclareOk |
queueDeclarePassive(java.lang.String queue) |
com.rabbitmq.client.AMQP.Queue.DeleteOk |
queueDelete(java.lang.String queue) |
com.rabbitmq.client.AMQP.Queue.DeleteOk |
queueDelete(java.lang.String queue,
boolean ifUnused,
boolean ifEmpty) |
void |
queueDeleteNoWait(java.lang.String queue,
boolean ifUnused,
boolean ifEmpty) |
com.rabbitmq.client.AMQP.Queue.PurgeOk |
queuePurge(java.lang.String queue) |
com.rabbitmq.client.AMQP.Queue.UnbindOk |
queueUnbind(java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey) |
com.rabbitmq.client.AMQP.Queue.UnbindOk |
queueUnbind(java.lang.String queue,
java.lang.String exchange,
java.lang.String routingKey,
java.util.Map<java.lang.String,java.lang.Object> arguments) |
boolean |
removeConfirmListener(com.rabbitmq.client.ConfirmListener listener) |
boolean |
removeFlowListener(com.rabbitmq.client.FlowListener 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 |
setDefaultConsumer(com.rabbitmq.client.Consumer consumer) |
void |
shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause) |
java.lang.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) |
public PublisherCallbackChannelImpl(com.rabbitmq.client.Channel delegate)
public void addShutdownListener(com.rabbitmq.client.ShutdownListener listener)
addShutdownListener
in interface com.rabbitmq.client.ShutdownNotifier
public void removeShutdownListener(com.rabbitmq.client.ShutdownListener listener)
removeShutdownListener
in interface com.rabbitmq.client.ShutdownNotifier
public com.rabbitmq.client.ShutdownSignalException getCloseReason()
getCloseReason
in interface com.rabbitmq.client.ShutdownNotifier
public void notifyListeners()
notifyListeners
in interface com.rabbitmq.client.ShutdownNotifier
public boolean isOpen()
isOpen
in interface com.rabbitmq.client.ShutdownNotifier
public int getChannelNumber()
getChannelNumber
in interface com.rabbitmq.client.Channel
public com.rabbitmq.client.Connection getConnection()
getConnection
in interface com.rabbitmq.client.Channel
public void close(int closeCode, java.lang.String closeMessage) throws java.io.IOException, java.util.concurrent.TimeoutException
close
in interface com.rabbitmq.client.Channel
java.io.IOException
java.util.concurrent.TimeoutException
@Deprecated public boolean flowBlocked()
flowBlocked
in interface com.rabbitmq.client.Channel
public void abort() throws java.io.IOException
abort
in interface com.rabbitmq.client.Channel
java.io.IOException
public void abort(int closeCode, java.lang.String closeMessage) throws java.io.IOException
abort
in interface com.rabbitmq.client.Channel
java.io.IOException
public void addFlowListener(com.rabbitmq.client.FlowListener listener)
addFlowListener
in interface com.rabbitmq.client.Channel
public boolean removeFlowListener(com.rabbitmq.client.FlowListener listener)
removeFlowListener
in interface com.rabbitmq.client.Channel
public void clearFlowListeners()
clearFlowListeners
in interface com.rabbitmq.client.Channel
public com.rabbitmq.client.Consumer getDefaultConsumer()
getDefaultConsumer
in interface com.rabbitmq.client.Channel
public void setDefaultConsumer(com.rabbitmq.client.Consumer consumer)
setDefaultConsumer
in interface com.rabbitmq.client.Channel
public void basicQos(int prefetchSize, int prefetchCount, boolean global) throws java.io.IOException
basicQos
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicQos(int prefetchCount, boolean global) throws java.io.IOException
basicQos
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicQos(int prefetchCount) throws java.io.IOException
basicQos
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicPublish(java.lang.String exchange, java.lang.String routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body) throws java.io.IOException
basicPublish
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicPublish(java.lang.String exchange, java.lang.String routingKey, boolean mandatory, boolean immediate, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body) throws java.io.IOException
basicPublish
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicPublish(java.lang.String exchange, java.lang.String routingKey, boolean mandatory, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body) throws java.io.IOException
basicPublish
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, java.lang.String type) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, java.lang.String type, boolean durable) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclare(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeclareOk exchangeDeclarePassive(java.lang.String name) throws java.io.IOException
exchangeDeclarePassive
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(java.lang.String exchange, boolean ifUnused) throws java.io.IOException
exchangeDelete
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.DeleteOk exchangeDelete(java.lang.String exchange) throws java.io.IOException
exchangeDelete
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind(java.lang.String destination, java.lang.String source, java.lang.String routingKey) throws java.io.IOException
exchangeBind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.BindOk exchangeBind(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeBind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind(java.lang.String destination, java.lang.String source, java.lang.String routingKey) throws java.io.IOException
exchangeUnbind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Exchange.UnbindOk exchangeUnbind(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeUnbind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare() throws java.io.IOException
queueDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclare(java.lang.String queue, boolean durable, boolean exclusive, boolean autoDelete, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
queueDeclare
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.DeclareOk queueDeclarePassive(java.lang.String queue) throws java.io.IOException
queueDeclarePassive
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(java.lang.String queue) throws java.io.IOException
queueDelete
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.DeleteOk queueDelete(java.lang.String queue, boolean ifUnused, boolean ifEmpty) throws java.io.IOException
queueDelete
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.BindOk queueBind(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey) throws java.io.IOException
queueBind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.BindOk queueBind(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
queueBind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey) throws java.io.IOException
queueUnbind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.UnbindOk queueUnbind(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
queueUnbind
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Queue.PurgeOk queuePurge(java.lang.String queue) throws java.io.IOException
queuePurge
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.GetResponse basicGet(java.lang.String queue, boolean autoAck) throws java.io.IOException
basicGet
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicAck(long deliveryTag, boolean multiple) throws java.io.IOException
basicAck
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicNack(long deliveryTag, boolean multiple, boolean requeue) throws java.io.IOException
basicNack
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicReject(long deliveryTag, boolean requeue) throws java.io.IOException
basicReject
in interface com.rabbitmq.client.Channel
java.io.IOException
public java.lang.String basicConsume(java.lang.String queue, com.rabbitmq.client.Consumer callback) throws java.io.IOException
basicConsume
in interface com.rabbitmq.client.Channel
java.io.IOException
public java.lang.String basicConsume(java.lang.String queue, boolean autoAck, com.rabbitmq.client.Consumer callback) throws java.io.IOException
basicConsume
in interface com.rabbitmq.client.Channel
java.io.IOException
public java.lang.String basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, com.rabbitmq.client.Consumer callback) throws java.io.IOException
basicConsume
in interface com.rabbitmq.client.Channel
java.io.IOException
public java.lang.String basicConsume(java.lang.String queue, boolean autoAck, java.util.Map<java.lang.String,java.lang.Object> arguments, com.rabbitmq.client.Consumer callback) throws java.io.IOException
basicConsume
in interface com.rabbitmq.client.Channel
java.io.IOException
public java.lang.String basicConsume(java.lang.String queue, boolean autoAck, java.lang.String consumerTag, boolean noLocal, boolean exclusive, java.util.Map<java.lang.String,java.lang.Object> arguments, com.rabbitmq.client.Consumer callback) throws java.io.IOException
basicConsume
in interface com.rabbitmq.client.Channel
java.io.IOException
public void basicCancel(java.lang.String consumerTag) throws java.io.IOException
basicCancel
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover() throws java.io.IOException
basicRecover
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Basic.RecoverOk basicRecover(boolean requeue) throws java.io.IOException
basicRecover
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Tx.SelectOk txSelect() throws java.io.IOException
txSelect
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Tx.CommitOk txCommit() throws java.io.IOException
txCommit
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Tx.RollbackOk txRollback() throws java.io.IOException
txRollback
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.AMQP.Confirm.SelectOk confirmSelect() throws java.io.IOException
confirmSelect
in interface com.rabbitmq.client.Channel
java.io.IOException
public long getNextPublishSeqNo()
getNextPublishSeqNo
in interface com.rabbitmq.client.Channel
public boolean waitForConfirms() throws java.lang.InterruptedException
waitForConfirms
in interface com.rabbitmq.client.Channel
java.lang.InterruptedException
public boolean waitForConfirms(long timeout) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
waitForConfirms
in interface com.rabbitmq.client.Channel
java.lang.InterruptedException
java.util.concurrent.TimeoutException
public void waitForConfirmsOrDie() throws java.io.IOException, java.lang.InterruptedException
waitForConfirmsOrDie
in interface com.rabbitmq.client.Channel
java.io.IOException
java.lang.InterruptedException
public void waitForConfirmsOrDie(long timeout) throws java.io.IOException, java.lang.InterruptedException, java.util.concurrent.TimeoutException
waitForConfirmsOrDie
in interface com.rabbitmq.client.Channel
java.io.IOException
java.lang.InterruptedException
java.util.concurrent.TimeoutException
public void asyncRpc(com.rabbitmq.client.Method method) throws java.io.IOException
asyncRpc
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.Command rpc(com.rabbitmq.client.Method method) throws java.io.IOException
rpc
in interface com.rabbitmq.client.Channel
java.io.IOException
public void addConfirmListener(com.rabbitmq.client.ConfirmListener listener)
addConfirmListener
in interface com.rabbitmq.client.Channel
public boolean removeConfirmListener(com.rabbitmq.client.ConfirmListener listener)
removeConfirmListener
in interface com.rabbitmq.client.Channel
public void clearConfirmListeners()
clearConfirmListeners
in interface com.rabbitmq.client.Channel
public void addReturnListener(com.rabbitmq.client.ReturnListener listener)
addReturnListener
in interface com.rabbitmq.client.Channel
public boolean removeReturnListener(com.rabbitmq.client.ReturnListener listener)
removeReturnListener
in interface com.rabbitmq.client.Channel
public void clearReturnListeners()
clearReturnListeners
in interface com.rabbitmq.client.Channel
public void exchangeBindNoWait(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeBindNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void exchangeDeclareNoWait(java.lang.String exchange, java.lang.String type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclareNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void exchangeDeclareNoWait(java.lang.String exchange, com.rabbitmq.client.BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeDeclareNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void exchangeDeleteNoWait(java.lang.String exchange, boolean ifUnused) throws java.io.IOException
exchangeDeleteNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void exchangeUnbindNoWait(java.lang.String destination, java.lang.String source, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
exchangeUnbindNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void queueBindNoWait(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
queueBindNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void queueDeclareNoWait(java.lang.String queue, boolean durable, boolean exclusive, boolean autoDelete, java.util.Map<java.lang.String,java.lang.Object> arguments) throws java.io.IOException
queueDeclareNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public void queueDeleteNoWait(java.lang.String queue, boolean ifUnused, boolean ifEmpty) throws java.io.IOException
queueDeleteNoWait
in interface com.rabbitmq.client.Channel
java.io.IOException
public long consumerCount(java.lang.String queue) throws java.io.IOException
consumerCount
in interface com.rabbitmq.client.Channel
java.io.IOException
public long messageCount(java.lang.String queue) throws java.io.IOException
messageCount
in interface com.rabbitmq.client.Channel
java.io.IOException
public com.rabbitmq.client.Channel getDelegate()
PublisherCallbackChannel
Channel
that
are not supported by this implementation.getDelegate
in interface PublisherCallbackChannel
Channel
.public void close() throws java.io.IOException, java.util.concurrent.TimeoutException
close
in interface com.rabbitmq.client.Channel
java.io.IOException
java.util.concurrent.TimeoutException
public void addListener(PublisherCallbackChannel.Listener listener)
addListener
in interface PublisherCallbackChannel
listener
- the listener.public java.util.Collection<PendingConfirm> expire(PublisherCallbackChannel.Listener listener, long cutoffTime)
PublisherCallbackChannel
PendingConfirm
s created before cutoffTime for the
supplied listener and return them to the caller.expire
in interface PublisherCallbackChannel
listener
- the listener.cutoffTime
- the time before which expired messages were created.public void handleAck(long seq, boolean multiple) throws java.io.IOException
handleAck
in interface com.rabbitmq.client.ConfirmListener
java.io.IOException
public void handleNack(long seq, boolean multiple) throws java.io.IOException
handleNack
in interface com.rabbitmq.client.ConfirmListener
java.io.IOException
public void addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
PublisherCallbackChannel
addPendingConfirm
in interface PublisherCallbackChannel
listener
- The listener.seq
- The key to the map.pendingConfirm
- The PendingConfirm object.public void handleReturn(int replyCode, java.lang.String replyText, java.lang.String exchange, java.lang.String routingKey, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) throws java.io.IOException
handleReturn
in interface com.rabbitmq.client.ReturnListener
java.io.IOException
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)
shutdownCompleted
in interface com.rabbitmq.client.ShutdownListener
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object