Ack 对所标识的消息的传递予以确认 [消费成功回复].

数组去重.

CheckTypeArray 检查是否交换机 支持的类型.

参数.

CreateBroker 获取.

同env 创建.

创建 Publishing.

GetBoolByEnvOf 通过env 获取 bool 值.

通过环境变成创建配置.

GetByEnvOf 通过env 获取 string 值.

GetDurationByEnvOf 通过env 获取 duration 值.

GetJsonByEnvBind 通过env 获取 object 值.

获取AMQP消息.

MessageParamsCreate 创建仅有消息体的消息参数.

MessageParamsOf 指定 交换器 和 routing Key 的消息.

Nack 对所标识的消息的传递予以否定 [消费失败].

NewClient 构建客户端.

NewClientWithEnv 通过环境变量构建.

NewConsumer init a Consumer of rabbitmq client.

创建交换机参数.

NewMessageWrapper 消息封装器.

NewPublisher init a Publisher of rabbitmq client.

NewSubscribeConsumer 创建定义 消费者[Routing Publish/Subscribe].

NewRoutingConsumerParams auto Ack.

NewRoutingConsumerParamsAck 自己 Ack.

NewRoutingExchangeParams routing 模式 创建交换机参数.

NewRoutingPublisher 构建路由Routing　推送器.

NewRoutingQueueParams 定义模式队列模式 默认 队列参数.

NewSimpleConsumerParams 简单队列模式 默认 消费者参数.

NewSimpleQueueMessageParam 简单队列消息.

NewSimpleQueueParams 简单队列模式 默认 队列参数.

NewSubscribeConsumer 创建定义 消费者[发布/订阅 Publish/Subscribe].

自动 Ack.

自己 Ack.

NewSubscribeQueueParams 定义模式队列模式 默认 队列参数.

NewSubscribeConsumer 创建定义 消费者[Topic Publish/Subscribe].

NewTopicConsumerParams auto Ack.

NewTopicConsumerParamsAck 自己 Ack.

获取 topic Exchange 参数.

NewTopicPublisher 构建Topic　推送器.

NewRoutingQueueParams 定义模式队列模式 默认 队列参数.

解析url.

Reject 对所标识的消息的传递予以拒绝 [拒绝消费].

(直接交换)比fanout多加了一层密码限制(routingKey).

广播.

首部.

主题.

可以匹配多个单词（或者零个）.

可以（只能）匹配一个单词.