mq_api.go

package mq

import "github.com/mangenotwork/extras/common/conf"

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

// 通知topic 加入新的设备连接
type MQDevice struct {
	Type string // add  del
	Topic string
	Device string
}

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

func NewMQ() MQ {
	switch conf.Arg.MqType {
	case "nsq":
		return new(MQNsqService)
	case "rabbit":
		return new(MQRabbitService)
	default:
		return new(MQNsqService)
	}
}