Package org.springframework.pulsar.listener

Interface PulsarMessageRecovererFactory<T>

Type Parameters:

T - message type

All Known Implementing Classes:

PulsarDeadLetterPublishingRecoverer

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface PulsarMessageRecovererFactory<T>

Factory interface for PulsarMessageRecoverer.

Author:

Soby Chacko, Chris Bono

Method Summary

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

Method Details

recovererForConsumer

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

Provides a message recoverer PulsarMessageRecoverer.

Parameters:

consumer - Pulsar consumer

Returns:

PulsarMessageRecoverer.