interface BaseBrokerOptions
Base options for a broker implementation
optionalnumber blockTimeout? :
How long to block for messages when polling
optional(data: Buffer) => unknown decode? :
Function to use for decoding messages
optional(data: unknown) => Buffer encode? :
Function to use for encoding messages
optionalnumber maxChunk? :
Max number of messages to poll at once
optionalstring name? :
Unique consumer name. See: https://redis.io/commands/xreadgroup/