func NewMNSTopic()

in topic.go [35:51]


func NewMNSTopic(name string, client MNSClient, qps ...int32) AliMNSTopic {
	if name == "" {
		panic("ali_mns: topic name could not be empty")
	}

	topic := new(MNSTopic)
	topic.client = client
	topic.name = name
	topic.decoder = NewAliMNSDecoder()

	qpsLimit := DefaultTopicQPSLimit
	if qps != nil && len(qps) == 1 && qps[0] > 0 {
		qpsLimit = qps[0]
	}
	topic.qpsMonitor = NewQPSMonitor(5, qpsLimit)
	return topic
}