func BuildProducer()

in golang/utils/ClientUtils.go [74:96]


func BuildProducer(nameserver string, ak string, sk string, topic ...string) rmq_client.Producer {

	// new producer instance
	producer, err := rmq_client.NewProducer(&rmq_client.Config{
		Endpoint: nameserver,
		Credentials: &credentials.SessionCredentials{
			AccessKey:    ak,
			AccessSecret: sk,
		},
	},
		rmq_client.WithTopics(topic...),
	)
	if err != nil {
		log.Fatal(err)
	}

	// start producer
	err = producer.Start()
	if err != nil {
		log.Fatal(err)
	}
	return producer
}