NewRabmqConnPool 创建一个连接池.

WithConsumeAckMultiple 设置是否批量确认消息.

WithConsumeAutoAck 设置是否自动确认消息.

WithConsumeExchangeAutoDelete 设置交换机是否自动删除.

WithConsumeExchangeDurable 设置交换机是否持久化.

WithConsumeExchangeInternal 设置交换机是否内部使用.

WithConsumeExchangeNoWait 设置是否阻塞等待交换机创建完成.

WithConsumeExclusive 设置是否独占消费.

WithConsumeNackMultiple 设置是否批量拒绝当前和之后的消息.

WithConsumeNackRequeue 设置重新消费策略.

WithConsumeNoLocal 设置是否消费本地消息.

WithConsumeNoWait 设置是否阻塞等待消费者创建完成.

WithConsumeQosGlobal 设置对当前mq连接所有channel生效.

WithConsumeQosPrefetchCount 设置每次从队列中获取的消息数量.

WithConsumeQosPrefetchSize 设置每次从队列中获取的消息大小.

WithConsumeQueueBindNoWait 设置是否阻塞等待队列创建完成.

WithConsumeQueueDurable 设置队列是否持久化.

WithIdleTimeout 设置连接池中最大连接数.

WithProducerDelay 设置消息延迟 // **新增延迟选项**.

WithProducerIsConfirm 设置确认模式.

WithProducerPublishDeliveryMode 设置消息传递失败后是否重试投递.

WithProducerPublishImmediate 设置路由失败时处理方法.

WithProducerPublishMandatory 设置未匹配到队列处理方法.

WithProducerPublishPriority 设置消息优先级.

默认最大连接数.

默认获取连接失败后重试间隔.

表示连接中.

表示连接断开.

RabmqConnPool 是一个RabbitMQ连接池结构体.

PoolOptinon 连接池配置选项.