mqlib

type Consumer struct {
	sync.RWMutex
	GroupName string
	// contains filtered or unexported fields
}

type GenericClient interface {
	RpcSrvClient
	PubSubClient
}

type Message struct {
	Id        string   `json:"id,omitempty"`         // 消息ID
	RemoteApp string   `json:"remote_app,omitempty"` // RPC调用服务端应用名称
	Topic     string   `json:"topic,omitempty"`      // 消息主题（可选）
	Tag       string   `json:"tag"`                  // RPC调用接口名称
	Keys      []string `json:"keys"`                 // 携带的业务KEY（可选）
	Body      []byte   `json:"-"`                    // 业务消息体
	// contains filtered or unexported fields
}

type Producer struct {
	GroupName string
	// contains filtered or unexported fields
}

type PubClient interface {
	GetPub() *Producer
	SetRpcTimeout(ttl time.Duration)
	SendMessage(msg *Message) error
	Request(msg *Message, ctx ...context.Context) (resp *Message, err error)
	RequestAsync(msg *Message, out chan *Message, ctx ...context.Context) error
	RequestAsyncWithFunc(msg *Message, callback RpcCallback, ctx ...context.Context) error
	// contains filtered or unexported methods
}

type PubSubClient interface {
	PubClient
	SubClient
}

type RpcCallback = func(msg *Message)

type RpcSrvClient interface {
	Respond(msg *Message) error
	// contains filtered or unexported methods
}

type SubCallback = func(msg *Message) error

type SubClient interface {
	GetSub() *Consumer
	SetDeDup(bool)
	// contains filtered or unexported methods
}

type SubDispatcher interface {
	ProcessMsg(msg *Message) error
}

type Topic struct {
	Name     string      // 订阅的topic名称
	Tags     []string    // 订阅的topic下的tag列表，可留空（表示订阅所有tag），订阅后不可修改
	Callback SubCallback // 订阅的topic+tag收到消息时的回调，在第一次订阅topic时指定，订阅后不可修改
}