mqwrapper

type Config struct {
	// Ready 协调各组件之间的状态，当一切就绪之后，Ready将可读，此时该组件开始对外释放能力
	Ready <-chan struct{}

	MQUrl string

	// 生产者配置
	EnableProducer       bool
	ProducerExchange     string
	ProducerExchangeKind string
	ProducerQueue        string
	ProducerRouteKey     string

	// 消费者配置
	EnableConsumer       bool
	ConsumerExchange     string
	ConsumerExchangeKind string
	ConsumerQueue        string
	ConsumerRouteKey     string

	// 日志写入，如果为空将不记录日志
	Debug LogWriter
	Info  LogWriter
	Warn  LogWriter
	Error LogWriter
}

type LogWriter interface {
	Println(format string, v ...interface{})
}

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

type MsgEncoder interface {
	Encode(actionKey int32, msgBody []byte) ([]byte, error)
	Decode(b []byte) (actionKey int32, msgBody []byte, err error)
}

type MsgHandler func(actionKey int32, msg []byte) error