Search...

RPCRedisBrokerOptions

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

blockTimeout?

:

number

How long to block for messages when pollingInherited from BaseBrokerOptions
Optional

decode?

:

(data: Buffer) => unknown

Function to use for decoding messagesInherited from BaseBrokerOptions
Optional

encode?

:

(data: unknown) => Buffer

Function to use for encoding messagesInherited from BaseBrokerOptions
Optional

maxChunk?

:

number

Max number of messages to poll at onceInherited from BaseBrokerOptions
Optional

name?

:

string

Unique consumer name. See: https://redis.io/commands/xreadgroup/Inherited from BaseBrokerOptions

redisClient

:

Redis

The Redis client to useInherited from RedisBrokerOptions
Optional

timeout?

:

number