123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960 |
- package main
- import (
- "demo/rabbitmq/go-rabbitmq/ra"
- "encoding/json"
- "github.com/wagslane/go-rabbitmq"
- )
- func main() {
- conn, _ := rabbitmq.NewConn(
- ra.MQUrl,
- rabbitmq.WithConnectionOptionsLogging,
- )
- defer conn.Close()
- pub, err := ra.NewPublisher(conn)
- if err != nil {
- }
- defer pub.Close()
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- var m = map[string]interface{}{
- "code": 200,
- "msg": "success",
- "status": false,
- }
- b, _ := json.Marshal(m)
- ra.SendMessage(
- ra.Message{
- ID: "ddf5379f-9299-405a-841b-01d19a4ea81d",
- Method: "createVM",
- Body: b,
- }, "", pub)
- }
|