NewBroker builds a new broker that uses redis streams as exchange mechanism.

WithAddress sets the address of the redis server.

WithDeliverTimeout how long to wait trying to send a message to a handler until we consider it has timed out.

WithJanitorConsumerTimeout threshold for an "old" consumer.

WithJanitorFrequency how often do we run the janitor.

WithLogger defines a logger for the broker.

WithPendingIdleTime how long in pending before we claim a message from a different consumer.

WithReadGroupTimeout how long to block on call to redis.

WithTrimDuration oldest event in stream.

Logger is the interface that provides methods to log messages.

Option represents an option that can be passed to redis broker.