Package org.springframework.pulsar.listener

Class PulsarDeadLetterPublishingRecoverer<T>

java.lang.Object

org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer<T>

Type Parameters:

T - payload type of the Pulsar message

All Implemented Interfaces:

PulsarMessageRecovererFactory<T>

public class PulsarDeadLetterPublishingRecoverer<T>
extends Object
implements PulsarMessageRecovererFactory<T>

PulsarMessageRecoverer implementation that is capable of recovering the message by publishing the failed record to a DLT - Dead Letter Topic.

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXCEPTION_THROWN_CAUSE	TODO: Move this to a common constants class.
protected final LogAccessor	logger

Constructor Summary

Constructors

Constructor	Description
PulsarDeadLetterPublishingRecoverer(PulsarOperations<T> pulsarTemplate)
PulsarDeadLetterPublishingRecoverer(PulsarOperations<T> pulsarTemplate, BiFunction<org.apache.pulsar.client.api.Consumer<?>,org.apache.pulsar.client.api.Message<?>,String> destinationResolver)

Method Summary

Modifier and Type	Method	Description
PulsarMessageRecoverer<T>	recovererForConsumer(org.apache.pulsar.client.api.Consumer<T> consumer)	Provides a message recoverer PulsarMessageRecoverer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

protected final LogAccessor logger

EXCEPTION_THROWN_CAUSE

public static final String EXCEPTION_THROWN_CAUSE

TODO: Move this to a common constants class. exception cause for the failed message.

See Also:

• Constant Field Values

Constructor Details

PulsarDeadLetterPublishingRecoverer

public PulsarDeadLetterPublishingRecoverer(PulsarOperations<T> pulsarTemplate)

PulsarDeadLetterPublishingRecoverer

public PulsarDeadLetterPublishingRecoverer(PulsarOperations<T> pulsarTemplate,
 BiFunction<org.apache.pulsar.client.api.Consumer<?>,org.apache.pulsar.client.api.Message<?>,String> destinationResolver)

Method Details

recovererForConsumer

public PulsarMessageRecoverer<T> recovererForConsumer(org.apache.pulsar.client.api.Consumer<T> consumer)

Description copied from interface: PulsarMessageRecovererFactory

Provides a message recoverer PulsarMessageRecoverer.

Specified by:

recovererForConsumer in interface PulsarMessageRecovererFactory<T>

Parameters:

consumer - Pulsar consumer

Returns:

PulsarMessageRecoverer.