package mq import ( "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "search_server/pkg/config" ) func PushMsg(listName string, data string) { queueExchange := rabbitmq.QueueExchange{ listName, listName, "", "direct", config.Get("rabmq.url").String(), } rabbitmq.Send(queueExchange, data) }