mq

type HandlerFunc func(message *Message) error

type MQ interface {
	Pub(topic string, msg any) MQ                      // Pub any message`
	MultiPub(topic string, msgs ...any) MQ             // MultiPub ...any message
	Sub(topic, channel string, handler HandlerFunc) MQ // consumer Sub func to handle your work
	Stop(topic, channel string) MQ                     // consumer Stop
	Error() error
}

type Message struct {
	Body      []byte
	MessageID string
}

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