Versions in this module Expand all Collapse all v0 v0.0.8 Nov 25, 2022 Changes in this version + var MQConn *amqp.Connection + func CommonDelayInit() error + func CommonFanoutInit() error + func CommonInit() error + func CommonTopicInit() error + func GetConn() *amqp.Connection + func InitConn(user string, pwd string, host string, port int) + type MQ struct + Channel *amqp.Channel + func NewMQ() *MQ + func (this *MQ) Consume(queue string, key string, ...) + func (this *MQ) DecQueueAndBind(queues string, key string, exchange string) error + func (this *MQ) ListenConfirm() + func (this *MQ) NotifyReturn() + func (this *MQ) SendDelayMessage(key string, exchange string, message string, delay int) error + func (this *MQ) SendFanoutMessage(exchange string, message string) error + func (this *MQ) SendMessage(key string, exchange string, message string) error + func (this *MQ) SetConfirm()
Go to main page