dlqmiddleware

package
v0.15.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2023 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WrapBatch

func WrapBatch(
	next goduck.BatchProcessor,
	brokers []string,
	topic, username, password string,
) goduck.BatchProcessor

WrapBatch wraps @next with a middleware that redirect any failed messages to a dlq. Fatal errors and parent context cancelation errors are ignored.

func WrapSingle

func WrapSingle(
	next goduck.Processor,
	brokers []string,
	topic, username, password string,
) goduck.Processor

WrapSingle wraps @next with a middleware that redirect any failed messages to a dlq. Fatal errors and parent context cancelation errors are ignored.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL