Documentation
¶
Overview ¶
* @Author: lisheng * @Date: 2022-11-15 15:36:07 * @LastEditTime: 2023-01-06 14:16:15 * @LastEditors: lisheng * @Description: * @FilePath: /jf-go-kit/database/rabbitmq/rabbitmq.go
* @Author: lisheng * @Date: 2022-11-20 00:05:12 * @LastEditTime: 2022-11-20 08:56:29 * @LastEditors: lisheng * @Description: * @FilePath: /gitee.com/liqiyuworks/jf-go-kit/database/rabbitmq/record.go
Index ¶
- func BindQueue(engineName, queue, exchange string, keys []string, nowait bool) (err error)
- func ConsumeQueue(engineName, queue string) (deliveries <-chan amqp.Delivery, err error)
- func DeclareExchange(engineName, name, typ string, durable, autodelete, nowait bool) (err error)
- func DeclareQueue(engineName, name string, durable, autodelete, exclusive, nowait bool) (err error)
- func DeleteExchange(engineName, name string) (err error)
- func DeleteQueue(engineName, name string) (err error)
- func InitRabbitMQClient() func() error
- func PublishQueue(engineName, exchange, key string, deliverymode, priority uint8, body string) (err error)
- func UnBindQueue(engineName, queue, exchange string, keys []string) (err error)
- type RabbitMQ
- type RabbitMQManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConsumeQueue ¶
*
- @description: ConsumeQueue - 消费者
- @param {*} engineName
- @param {string} queue
- @return {*}
- @author: liqiyuWorks
func DeclareExchange ¶
func DeclareQueue ¶
*
- @description: DeclareQueue 创建队列
- @param {string} name
- @param {*} durable
- @param {*} autodelete
- @param {*} exclusive
- @param {bool} nowait
- @return {*}
- @author: liqiyuWorks
func DeleteExchange ¶
func DeleteQueue ¶
*
- @description: DeleteQueue 删除队列
- @param {*} engineName
- @param {string} name
- @return {*}
- @author: liqiyuWorks
func InitRabbitMQClient ¶
func InitRabbitMQClient() func() error
func PublishQueue ¶
func PublishQueue(engineName, exchange, key string, deliverymode, priority uint8, body string) (err error)
*
- @description: 生成消息
- @param {*} engineName
- @param {*} exchange
- @param {string} key
- @param {*} deliverymode
- @param {uint8} priority
- @param {string} body
- @return {*}
- @author: liqiyuWorks
func UnBindQueue ¶
Types ¶
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
RabbitMQ Operate Wrapper
func CreateDBEngnine ¶
type RabbitMQManager ¶
var (
GRabbitMQManager *RabbitMQManager = new(RabbitMQManager)
)
Source Files
Click to show internal directories.
Click to hide internal directories.