mq

type Config struct {
	Host          string              `json:"host"`
	Port          string              `json:"port"`
	DashboardHost string              `json:"dashboard_host"`
	DashboardPort string              `json:"dashboard_port"`
	MaxOpenConn   int                 `json:"max_open_conn"` // 允许的最大连接数, 即 生产者+消费者最多有 MaxOpenConn 个
	BufferSize    int                 `json:"buffer_size"`   // 生产者消息历史记录最大数量
	Logger        logger.Iface        `json:"-"`
	Crypto        proto.Crypto        `json:"-"` // 加密器
	EventHandler  engine.EventHandler // 事件触发器
}

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