func BuildTransactionProducer()

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
}