zmq

type ZeroMQ struct {
	Log     logger.Logger // 日志
	Verbose bool          // 是否打印信息
	Pull    *ZeroMQArgs
	Push    *ZeroMQArgs
	Pub     *ZeroMQArgs
	Sub     *ZeroMQArgs
	// contains filtered or unexported fields
}

type ZeroMQArgs struct {
	ConnStr          string        // 连接字符串
	Timeo            time.Duration // IO超时
	ChannelCache     int           // 信号通道大小，默认2k
	Subscribe        []string      //  sub过滤器
	ReconnectIfTimeo bool
}

type ZeroMQData struct {
	RoutingKey string
	Body       []byte
}