func BuildProducerWithDefaultInfo()

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
}