consumer

type EventConsumer interface {
	Run(ctx context.Context) error
}

type EventConsumerHandler interface {
	Apply(event eventstorming.Event) error
}

type RedisEventConsumer struct {
	RedisURL         string
	DBIndex          string
	Password         string
	Group            string
	Consumer         string
	NewMessage       bool
	Foreground       bool
	HandlerConsumers map[string]EventConsumerHandler
	LogFunction      func(functionName string, message string)
}