dlqmiddleware

Documentation

Index

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

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.