Search...

RPCRedisBrokerOptions

export declare interface RPCRedisBrokerOptions extends RedisBrokerOptions 
export declare interface RPCRedisBrokerOptions extends RedisBrokerOptions 
Options specific for an RPC Redis broker
Optional

blockTimeout?

:

number

How long to block for messages when polling
Inherited from BaseBrokerOptions
Optional

decode?

:

(data: Buffer_2) => unknown

Function to use for decoding messages
Inherited from BaseBrokerOptions
Optional

encode?

:

(data: unknown) => Buffer_2

Function to use for encoding messages
Inherited from BaseBrokerOptions
Optional

maxChunk?

:

number

Max number of messages to poll at once
Inherited from BaseBrokerOptions
Optional

name?

:

string

Unique consumer name.
Inherited from BaseBrokerOptions

redisClient

:

Redis

The Redis client to use
Inherited from RedisBrokerOptions
Optional

timeout?

:

number