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
}