export declare interface BaseBrokerOptions export declare interface BaseBrokerOptions Base options for a broker implementation
Optional
blockTimeout?
:
number
How long to block for messages when polling
Optional
decode?
:
(data: Buffer_2) => unknown
Function to use for decoding messages
Optional
encode?
:
(data: unknown) => Buffer_2
Function to use for encoding messages
Optional
maxChunk?
:
number
Max number of messages to poll at once
Optional
name?
:
string
Unique consumer name.