queue

type Client interface {
	Send(msg Message, waitReply bool) (err error) //同步发送消息
	SendTimeout(msg Message, waitReply bool, timeout time.Duration) (err error)
	Wait(msg Message) (Message, error)                               //等待消息处理完成
	WaitTimeout(msg Message, timeout time.Duration) (Message, error) //等待消息处理完成
	Recv() chan Message
	Sub(topic string) //订阅消息
	Close()
	CloseQueue() (*types.Reply, error)
	NewMessage(topic string, ty int64, data interface{}) (msg Message)
}

type Message struct {
	Topic string
	Ty    int64
	ID    int64
	Data  interface{}
	// contains filtered or unexported fields
}

type Module interface {
	SetQueueClient(client Client)
	//wait for ready
	Wait()
	Close()
}

type Queue interface {
	Close()
	Start()
	Client() Client
	Name() string
}