mq

type HandlerFunc func(message *Message) error

type MQ interface {
	NewProducer() MQ                          // new producer
	NewConsumer(topic, channel string) MQ     // new consumer
	Stop()                                    // consumer Stop
	Pub(topic string, msg any) error          // pub any message
	MultiPub(topic string, msgs ...any) error // MultiPub ...any message
	Sub(handler HandlerFunc) error            // sub func to handle your work
}

type Message struct {
	*nsq.Message
}

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