rabbitmq.go

package main

import "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"

func main()  {
	PushMsg("ws_test","abc")
}


func PushMsg(listName string, data string) {
	queueExchange := rabbitmq.QueueExchange{
		listName,
		listName,
		"",
		"direct",
		"amqp://guest:guest@192.168.1.252:5672/",
	}
	rabbitmq.Send(queueExchange, data)
}