RedisBrokerOptions
Options specific for a Redis broker
interface RedisBrokerOptions extends BaseBrokerOptions interface RedisBrokerOptions extends BaseBrokerOptions 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 use