smq

type Client interface {
	Connect() error
	Pub(topic string, message []byte, option ...Option) error
	Sub(topic string, subscriber Subscriber) error
	Close() error
}

type Exchange struct {
	Type  string // 交换机类型
	Name  string // 交换机名称
	Key   string // key值
	Queue string // 队列名称
}

type Option func(ops *Options)

type Options struct {
	Ack bool
	TTL time.Duration
}

type Subscriber func(client Client, topic string, message []byte, options Options) (err error)