interface RPCRedisBrokerOptions

export interface RPCRedisBrokerOptions extends RedisBrokerOptions

Options specific for an RPC Redis broker

optional
blockTimeout? : number

How long to block for messages when polling

Inherited from: RedisBrokerOptions

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

Function to use for decoding messages

Inherited from: BaseBrokerOptions

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

Function to use for encoding messages

Inherited from: BaseBrokerOptions

group : string

Consumer group name to use for this broker

Inherited from: RedisBrokerOptions

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

optional
maxChunk? : number

Max number of messages to poll at once

Inherited from: RedisBrokerOptions

optional
name? : string

Unique consumer name.

Inherited from: RedisBrokerOptions

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

optional
timeout? : number