Package org.springframework.pulsar.reactive.config

Interface ReactivePulsarListenerEndpoint<T>

Type Parameters:

T - Message payload type.

All Superinterfaces:

ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>

All Known Implementing Classes:

AbstractReactivePulsarListenerEndpoint, MethodReactivePulsarListenerEndpoint, ReactivePulsarListenerEndpointAdapter

public interface ReactivePulsarListenerEndpoint<T>
extends ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>

Model for a Pulsar reactive listener endpoint. Can be used against a ReactivePulsarListenerConfigurationSelector to register endpoints programmatically.

Author:

Christophe Bornet, Chris Bono, Vedran Pavic

Method Summary

Modifier and Type	Method	Description
default Boolean	getUseKeyOrderedProcessing()
default boolean	isFluxListener()

Methods inherited from interface org.springframework.pulsar.config.ListenerEndpoint

getAutoStartup, getConcurrency, getId, getSchemaType, getSubscriptionName, getSubscriptionType, getTopicPattern, getTopics, setupListenerContainer

Method Details

isFluxListener

default boolean isFluxListener()

getUseKeyOrderedProcessing

@Nullable
default Boolean getUseKeyOrderedProcessing()