Package io.gravitee.gateway.reactive.api.service.dlq

Interface DlqService

public interface DlqService

Allows applying behavior on a flow of messages in order to filter messages in error and send them ot a Dead Letter Queue.

Author:

Jeoffrey HAEYAERT (jeoffrey.haeyaert at graviteesource.com), GraviteeSource Team

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Message>	apply(io.reactivex.rxjava3.core.Flowable<Message> messages)	Set up the dead letter queue mechanism on the incoming flow of messages.

Method Details

apply

io.reactivex.rxjava3.core.Flowable<Message> apply(io.reactivex.rxjava3.core.Flowable<Message> messages)

Set up the dead letter queue mechanism on the incoming flow of messages. It is the responsibility of the implementation to filter incoming messages and send only the appropriate subset of messages to the DLQ (ex: message in error, message matching a particular condition, ..).

Parameters:

messages - the incoming flow of messages.

Returns:

the original flow of messages, so it can be chained easily.