mq.go

package mq

import (
	"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
	"go_sku_server/pkg/config"
)

func PushMsg(listName string, data string) {
	queueExchange := rabbitmq.QueueExchange{
		listName,
		listName,
		"",
		"direct",
		config.Get("rabmq.url").String(),
	}
	rabbitmq.Send(queueExchange, data)
}