consumer

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

type DLQOptions struct {
	Topic            string
	Throttle         bool
	ThrottleDuration time.Duration
	ThrottleCount    int64
}

type Options struct {
	SystemEventsTopic string
	Subscriber        message.Subscriber

	Publisher message.Publisher

	DLQ *DLQOptions

	Entitlement *registry.Entitlement

	Logger *slog.Logger
}