RedisBrokerOptions

interface RedisBrokerOptions extends BaseBrokerOptions
interface RedisBrokerOptions extends BaseBrokerOptions
Options specific for a Redis broker
blockTimeout?:number
How long to block for messages when polling
Inherited from BaseBrokerOptions
decode?:(data: Buffer) => unknown
Function to use for decoding messages
Inherited from BaseBrokerOptions
encode?:(data: unknown) => Buffer
Function to use for encoding messages
Inherited from BaseBrokerOptions
maxChunk?:number
Max number of messages to poll at once
Inherited from BaseBrokerOptions
name?:string
Unique consumer name. See: https://redis.io/commands/xreadgroup/
Inherited from BaseBrokerOptions
redisClient:Redis
The Redis client to use