in topic.go [90:104]
func (p *MNSTopic) SetSubscriptionAttributes(subscriptionName string, notifyStrategy NotifyStrategyType) (err error) {
subscriptionName = strings.TrimSpace(subscriptionName)
if err = checkTopicName(subscriptionName); err != nil {
return
}
message := SetSubscriptionAttributesRequest{
NotifyStrategy: notifyStrategy,
}
p.qpsMonitor.checkQPS()
_, err = send(p.client, p.decoder, PUT, nil, message, fmt.Sprintf("topics/%s/subscriptions/%s?metaoverride=true", p.name, subscriptionName), nil)
return
}