redissub

var (
	ErrEmptyTopic                    = errors.New("multi_subscriber: topic cannot be empty")
	ErrSubscriberCreation            = errors.New("multi_subscriber: failed to create subscriber")
	ErrClosingSubscribers            = errors.New("multi_subscriber: errors while closing subscribers")
	ErrNoSubscribers                 = errors.New("multi_subscriber: no subscribers registered")
	ErrMultiSubscriberAlreadyRunning = errors.New("multi_subscriber: already running")
)

var (
	ErrNilRedisClient           = errors.New("subscriber: redis client cannot be nil")
	ErrEmptyConsumerGroup       = errors.New("subscriber: consumer group name cannot be empty")
	ErrEmptyTopicName           = errors.New("subscriber: topic name cannot be empty")
	ErrNilMessageHandler        = errors.New("subscriber: message handler cannot be nil")
	ErrMessageHandlerNotDefined = errors.New("subscriber: message handler is not defined")
	ErrMaxRetriesExceeded       = errors.New("subscriber: max retries exceeded")
	ErrExecTimeout              = errors.New("subscriber: message handler execution timed out")
	ErrAlreadyRunning           = errors.New("subscriber: already running")
)