interface BaseBrokerOptions

export interface BaseBrokerOptions

Base options for a broker implementation

optional
decode? : (data: Buffer) => unknown

Function to use for decoding messages

optional
encode? : (data: unknown) => Buffer

Function to use for encoding messages