mq

type ConsumerHandler interface {
	OnMessage(msg string, ctx context.Context)
}

type MessageQueueHandler interface {
	Publish(channel string, msg string, ctx context.Context) error
	Subscribe(channel string, consumer ConsumerHandler) error
}

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