方法详细说明

void close()

throws java.io.IOException,

java.util.concurrent.TimeoutException

关闭 这个频道，同时附带 AMQP.REPLY_SUCCESS 这个关闭代码及消息'OK'。

抛出异常 ：

java.io.IOException  - 如果 发生错误，则抛出此异常

java.util.concurrent.TimeoutException

void abort()

throws java.io.IOException

终止 这个频道，同时附带 AMQP.REPLY_SUCCESS 这个关闭代码及消息'OK'。强制 让这个频道关闭，并且等待关闭操作执行完毕 。 在这个关闭过程中发生的任何异常，都会被静静地忽略掉。

抛出异常 ：

java.io.IOException

void addConfirmListener( ConfirmListener  listener)

boolean removeConfirmListener( ConfirmListener  listener)

void clearConfirmListeners()

移除所有 的 ConfirmListener 。

Consumer  getDefaultConsumer()

获取当前的默认消费者。参考setDefaultConsumer。

返回 ：

当前默认消费者的一个接口。

void setDefaultConsumer( Consumer  consumer)

设置当前的默认消费者。在特定的情况下，可能会发生这样的事：某个频道接收到一条消息，而该消息却并不匹配通过basicConsume()设置的任何消费者。在发生了以下事件序列之后，就可能发生这种事：

void basicQos(int prefetchSize,

int prefetchCount,

boolean global)

throws java.io.IOException

请求做出特定的"服务质量"设置。这些设置，控制的是，服务器在接收到确认消息之前，会向消费者传递的数据的数量。它们提供了一种由消费者主导的流控手段。

参数 ：

prefetchSize  - 服务器传递 的内容的最大长度 ( 以 八位元组（octets）的个数来度量 ) ， 0表示 无限制

prefetchCount  - 服务器传递 的最大消息个数， 0表示 无限制

global  - 为真（ true ）则表示，这些设置，应当 被应用到整个频道 ，而不是只应用到单个消费者

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Basic.Qos

void basicQos(int prefetchCount,

boolean global)

throws java.io.IOException

请求为此频道应用一个指定预取个数（prefetchCount）的"服务质量"设置。

参数 ：

prefetchCount  - 服务器传递 的最大消息个数， 0表示 无限制

global  - 为真（ true ）则表示，这些设置，应当 被应用到整个频道 ，而不是只应用到单个消费者

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

basicQos(int, int, boolean)

void basicQos(int prefetchCount)

throws java.io.IOException

请求为此频道应用一个指定预取个数（prefetchCount）的"服务质量"设置。

参数 ：

prefetchCount  - 服务器传递 的最大消息个数， 0表示 无限制

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

basicQos(int, int, boolean)

void basicPublish(java.lang.String exchange,

java.lang.String routingKey,

AMQP.BasicProperties  props,

byte[] body)

throws java.io.IOException

void basicPublish(java.lang.String exchange,

java.lang.String routingKey,

boolean mandatory,

AMQP.BasicProperties  props,

byte[] body)

throws java.io.IOException

void basicPublish(java.lang.String exchange,

java.lang.String routingKey,

boolean mandatory,

boolean immediate,

AMQP.BasicProperties  props,

byte[] body)

throws java.io.IOException

AMQP.Exchange.DeclareOk  exchangeDeclare(java.lang.String exchange,

java.lang.String type)

throws java.io.IOException

主动声明一个非自动删除（non-autodelete）、非持久性（non-durable）的交换机，不带任何其它参数。

参数 ：

exchange  - 交换机 的名字

type  - 交换机 的类型

返回 ：

一个声明确认方法，用来表明交换机已被成功声明。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Exchange.DeclareOk  exchangeDeclare(java.lang.String exchange,

java.lang.String type,

boolean durable)

throws java.io.IOException

主动声明一个非自动删除（non-autodelete）的交换机，不带任何其它参数。

参数 ：

exchange  - 交换机 的名字

type  - 交换机 的类型

durable  - 为真（ true ）则表明声明一个持久性（durable）的交换机（ 当服务器重启后，此交换机仍然存在 ）

返回 ：

一个声明确认方法，用来表明交换机已被成功声明。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

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

声明一个交换机。

参数 ：

exchange  - 交换机 的名字

type  - 交换机 的类型

durable  - 为真（ true ）则表明声明一个持久性（durable）的交换机（ 当服务器重启后，此交换机仍然存在 ）

autoDelete  - 为真（ true ）则表明，当该交换机不再被使用时，应当由服务器删除

arguments  - 该交换机的其它属性 (构造参数)

返回 ：

一个声明确认方法，用来表明交换机已被成功声明。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

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

通过一个允许传递完整参数集合的接口来声明一个交换机。

参数 ：

exchange  - 交换机 的名字

type  - 交换机 的类型

durable  - 为真（ true ）则表明声明一个持久性（durable）的交换机（ 当服务器重启后，此交换机仍然存在 ）

autoDelete  - 为真（ true ）则表明，当该交换机不再被使用时，应当由服务器删除

internal  - 为真（ true ）则表明， 该交换机是内部使用的，也就是说，客户端 不可以直接向该交换机发布消息。

arguments  - 该交换机的其它属性 (构造参数)

返回 ：

一个声明确认方法，用来表明交换机已被成功声明。

抛出异常：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Exchange.DeleteOk  exchangeDelete(java.lang.String exchange)

throws java.io.IOException

删除一个交换机，无论它是否正在使用

参数 ：

exchange  - 交换机 的名字

返回 ：

一个删除确认方法，用来表明交换机已被成功删除。

抛出异常：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Queue.DeclareOk  queueDeclare()

throws java.io.IOException

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

声明一个队列

Parameters:

queue  - 队列的名字

durable  - 为真（ true ），则表明，我们要声明一个持久（durable）队列 (服务器重启之后 ，该队列仍然存在 )

exclusive  - 为真（ true ），则表明，我们要声明一个排他性（exclusive）的队列 ( 仅限于这个连接中 )

autoDelete  - 为真（ true ），则表明，我们要声明一个自动删除的队列 (服务器 会在它不再被使用时删除它 )

arguments  - 队列 的其它属性 (构造参数)

返回 ：

一个声明确认方法，用来表明队列已被成功声明。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Queue.DeleteOk  queueDelete(java.lang.String queue)

throws java.io.IOException

删除一个队列，无论它是否正被使用、是否包含着消息

参数 ：

queue  - 队列的名字

返回 ：

一个删除确认方法，用来表明队列已被成功删除。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Queue.BindOk  queueBind(java.lang.String queue,

java.lang.String exchange,

java.lang.String routingKey)

throws java.io.IOException

将某个队列绑定到一个交换机，不带任何其它参数。

参数 ：

queue  - 队列的名字

exchange  - 交换机 的名字

routingKey  - 用于绑定过程 的路由键

返回 ：

一个绑定确认方法，用来表明绑定已被成功创建。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

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

将某个队列与一个交换机绑定。

参数 ：

queue  - 队列的名字

exchange  - 交换机 的名字

routingKey  - 用于绑定过程 的路由键

arguments  - 其它 属 性(绑定参数)

返回 ：

一个绑定确认方法，用来表明绑定已被成功创建。

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

AMQP.Queue.UnbindOk  queueUnbind(java.lang.String queue,

java.lang.String exchange,

java.lang.String routingKey)

throws java.io.IOException

将某个队列与某个交换机解除绑定，不带任何其它参数。

参数 ：

queue  - 队列的名字

exchange  - 交换机 的名字

routingKey  - 用于绑定过程 的路由键

返回 ：

一个解除绑定确认方法，表明，该绑定是否被成功删除

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

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

解除某个队列与某个交换机的绑定。

参数 ：

queue  - 队列的名字

exchange  - 交换机 的名字

routingKey  - 用于绑定过程 的路由键

arguments  - 其它参数(绑定参数)

返回 ：

一个解除绑定确认方法，表明，该绑定是否被成功删除

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

void basicAck(long deliveryTag,

boolean multiple)

throws java.io.IOException

java.lang.String basicConsume(java.lang.String queue,

Consumer  callback)

throws java.io.IOException

启动一个非本地的（non-nolocal）、非排他性的（non-exclusive）消费者，并且使用显式的确认及服务器生成的消费者标记（consumerTag）。

参数 ：

queue  - 队列的名字

callback  - 消费 者对象的接口

返回 ：

由服务器生成的消费者标记（consumerTag）

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

java.lang.String basicConsume(java.lang.String queue,

boolean autoAck,

Consumer  callback)

throws java.io.IOException

启动一个非本地的（non-nolocal）、非排他性的（non-exclusive）消费者，并且使用服务器生成的消费者标记（consumerTag）。

参数 ：

queue  - 队列的名字

autoAck  - 为真（ true ），则表明， 当消息被传递到消费者时，服务器就可以认为它已经被确认了； 为假（ false ），则表明，服务 器应当期待 着收到显式的确认

callback  - 消费 者对象的接口

返回 ：

由服务器生成的消费者标记（consumerTag）

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

java.lang.String basicConsume(java.lang.String queue,

boolean autoAck,

java.util.Map<java.lang.String,java.lang.Object> arguments,

Consumer  callback)

throws java.io.IOException

启动一个非本地的（non-nolocal）、非排他性的（non-exclusive）消费者，并且使用指定的参数和服务器生成的消费者标记（consumerTag）。

参数 ：

queue  - 队列的名字

autoAck  - 为真（ true ），则表明， 当消息被传递到消费者时，服务器就可以认为它已经被确认了； 为假（ false ），则表明，服务 器应当期待 着收到显式的确认

arguments  - 针对消费 者设置的一系列参数

callback  - 消费 者对象的接口

返回 ：

由服务器生成的消费者标记（consumerTag）

抛出异常 ：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

java.lang.String basicConsume(java.lang.String queue,

boolean autoAck,

java.lang.String consumerTag,

Consumer  callback)

throws java.io.IOException

启动一个非本地的（non-nolocal）、非排他性的（non-exclusive）消费者。

参数 ：

queue  - 队列的名字

autoAck  - 为真（ true ），则表明， 当消息被传递到消费者时，服务器就可以认为它已经被确认了； 为假（ false ），则表明，服务 器应当期待 着收到显式的确认

consumerTag  - 由客户端生成的消费者标记，用来建立上下文联系

callback  - 消费 者对象的接口

返回 ：

与新的消费者相关联的消费者标记（consumerTag）

抛出异常：

java.io.IOException  - 如果出现错误 ， 则 抛出此异常

参考 ：

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,

Consumer  callback)

throws java.io.IOException

void basicCancel(java.lang.String consumerTag)

throws java.io.IOException

取消 一个消费者。调用该消费者的 Consumer.handleCancelOk(java.lang.String) 方法。

参数 ：

consumerTag  - 由客户端或服务器生成的用来关联上下文的消费者标记

抛出异常：

java.io.IOException  - 如果 发生了错误，或者，该消费者标记（consumerTag）是未知的，则抛出此异常

参考 ：

AMQP.Confirm.SelectOk  confirmSelect()

throws java.io.IOException

在这个频道上启用发布者确认功能。

抛出异常：

java.io.IOException  - 如果 发生了错误，则抛出此异常

参考 ：

void asyncRpc( Method  method)

throws java.io.IOException

在这个频道上，异步地发送一个方法。

参数 ：

method  - 要通过这个频道传输的方法。

抛出异常 ：

java.io.IOException  - 如果 在传输方法的过程中出现问题，则抛出此异常。