mns

type Client interface {
	// 生成params的sign字段
	GenerateSign(str string) string

	// 添加队列
	AddQueue(name string, handler QueueHandler, waitSecond int)

	// 获取队列
	GetQueue(name string) Queue

	// 监听队列
	ListenQueues()

	PublishMessage(topicName string, params Params, filterTag string) (*ali_mns.MessageSendResponse, error)
}

type Params struct {
	Content          interface{} `json:"content"`
	Tag              string      `json:"tag"`
	TraceId          string      `json:"trace_id"`
	ReferServiceName string      `json:"refer_service_name"`
	Sign             string      `json:"sign"`
}

type Queue struct {
	Name string // 队列名称

	WaitSecond int
	// contains filtered or unexported fields
}

type QueueHandler func(params Params) error

type Topic struct {
	Name     string
	Instance ali_mns.AliMNSTopic
}