service/consumer/errors.go

package consumer

import "errors"

var (
	ErrNoMessage = errors.New("no message")
)