interface RPCRedisBrokerOptions
extends
RedisBrokerOptionsinterface RPCRedisBrokerOptions extends RedisBrokerOptions
Options specific for an RPC Redis broker
optionalnumber blockTimeout? :
How long to block for messages when polling
Inherited from: BaseBrokerOptions
optional(data: Buffer) => unknown decode? :
Function to use for decoding messages
Inherited from: BaseBrokerOptions
optional(data: unknown) => Buffer encode? :
Function to use for encoding messages
Inherited from: BaseBrokerOptions
optionalstring name? :
Unique consumer name. See: https://redis.io/commands/xreadgroup/
Inherited from: BaseBrokerOptions