hpds_node/example/multi-mq/mq1/main.go

package main

import (
	"git.hpds.cc/Component/network/log"
	"git.hpds.cc/pavement/hpds_node"
	"os"
)

func main() {
	mq, err := hpds_node.NewMq("mq_1.yaml")
	if err != nil {
		panic(err)
	}
	mq.InitOptions(hpds_node.WithAuth("token", "06d36c6f5705507dae778fdce90d0767"))
	defer func(mq hpds_node.MessageQueue) {
		_ = mq.Close()
	}(mq)

	// add Downstream mq
	_ = mq.AddDownstreamMq(hpds_node.NewDownstreamMq(
		"mq-2",
		hpds_node.WithMqAddr("localhost:27187"),
		hpds_node.WithCredential("token:z2"),
	))

	// start mq service
	log.Printf("Server has started!, pid: %d", os.Getpid())
	go func() {
		err := mq.ListenAndServe()
		if err != nil {
			panic(err)
		}
	}()
	select {}
}