Class KafkaDlqPublisher

Implements

DlqPublisher

Index

Constructors

Methods

connect disconnect publish

Constructors

constructor

new KafkaDlqPublisher(
    brokers: string[],
    clientId: string,
    topic: string,
    logger?: Logger,
): KafkaDlqPublisher
Parameters
- brokers: string[]
- clientId: string
- topic: string
- Optionallogger: Logger
Returns KafkaDlqPublisher
- Defined in src/infrastructure/messaging/KafkaDlqPublisher.ts:11

Methods

connect

connect(): Promise<void>
Returns Promise<void>
- Defined in src/infrastructure/messaging/KafkaDlqPublisher.ts:27

disconnect

disconnect(): Promise<void>
Returns Promise<void>
- Defined in src/infrastructure/messaging/KafkaDlqPublisher.ts:31

publish

publish(raw: string, reason: unknown): Promise<void>
Parameters
- raw: string
- reason: unknown
Returns Promise<void>
Implementation of DlqPublisher.publish
- Defined in src/infrastructure/messaging/KafkaDlqPublisher.ts:35