ConsumeTimeout indicates the maximum amount of time for an event to be in a handling state.

HandlingNumberOfAttempts indicates how many times an event will be processed if the handler errors.

Publisher creates a publisher that uses redis streams under the hood.

ReadingBatchCapacity indicates how many events can be taken out of the stream at once.

RunFailureRecovery enables the execution of the redis xautoclaim command, running it on the indicated cadence.

StreamForPublisher creates a Stream that will know the event types that will use a redis stream with such name in order to publish messages into.

StreamsForSubscriber creates a list of Stream to indicate all the redis streams a subscriber has to read events from.

Subscriber creates a subscriber that uses redis streams under the hood.

Stream let's both –producers and consumers– know what redis streams to interact with.

SubscriberOption allows to tweak subscriber behavior.