mq

type MQ interface {
	Producer(topic string, data []byte)
	Consumer(topic string, ch chan []byte, f func(b []byte))
}

type MQDevice struct {
	Type   string // add  del
	Topic  string
	Device string
}

type MQMsg struct {
	Topic    string `json:"topic"`
	Message  string `json:"message"`
	SendTime string `json:"send_time"`
}

type MQNsqService struct {
}

type MQRabbitService struct {
}