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
}