emq

type Emq struct {
	Cli         client.Client
	Opts        *client.ClientOptions
	Evt         chan client.Message
	SysProtocol map[string]client.MessageHandler
	BizProtocol map[string]Handler
	Cancel      context.CancelFunc
	Ctx         context.Context
	Version     string
}

type FSM interface {
	Init(opts []Option)
	Run()
	Stop()
}

type Handler func(*Emq, json.RawMessage) error

type Option func(*Emq) error