in golang/utils/ClientUtils.go [98:119]
func BuildTransactionProducer(nameserver string, ak string, sk string, checker *rmq_client.TransactionChecker, topics ...string) rmq_client.Producer {
producer, err := rmq_client.NewProducer(&rmq_client.Config{
Endpoint: nameserver,
Credentials: &credentials.SessionCredentials{
AccessKey: ak,
AccessSecret: sk,
},
},
rmq_client.WithTransactionChecker(checker),
rmq_client.WithTopics(topics...),
)
if err != nil {
log.Fatal(err)
}
// start producer
err = producer.Start()
if err != nil {
log.Fatal(err)
}
return producer
}