in golang/utils/ClientUtils.go [51:72]
func BuildProducerWithDefaultInfo(topic ...string) rmq_client.Producer {
producer, err := rmq_client.NewProducer(&rmq_client.Config{
Endpoint: NAMESERVER,
Credentials: &credentials.SessionCredentials{
AccessKey: ACCESS_KEY,
AccessSecret: SECRET_KEY,
},
},
rmq_client.WithTopics(topic...),
)
if err != nil {
log.Fatal(err)
}
// start producer
err = producer.Start()
if err != nil {
log.Fatal(err)
}
return producer
}