interface BaseBrokerOptions

export declare interface BaseBrokerOptions

Base options for a broker implementation

optional
blockTimeout? : number

How long to block for messages when polling

optional
decode? : (data: Buffer_2) => unknown

Function to use for decoding messages

optional
encode? : (data: unknown) => Buffer_2

Function to use for encoding messages

optional
maxChunk? : number

Max number of messages to poll at once

optional
name? : string

Unique consumer name.

See also: https://redis.io/commands/xreadgroup/