auramq

type Broker interface {
	Run()
	Close()
	NeedAuth() bool
	Auth(auth *msg.AuthReq) bool
}

type RegMsg struct {
	// contains filtered or unexported fields
}

type Router struct {
	// contains filtered or unexported fields
}

type Subscriber interface {
	Send(msg *msg.Message) bool
	Run()
	Close()
}