Package org.springframework.pulsar.config

Interface PulsarListenerEndpoint

All Superinterfaces:

ListenerEndpoint<PulsarMessageListenerContainer>

All Known Implementing Classes:

AbstractPulsarListenerEndpoint, MethodPulsarListenerEndpoint, PulsarListenerEndpointAdapter

public interface PulsarListenerEndpoint
extends ListenerEndpoint<PulsarMessageListenerContainer>

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

Author:

Soby Chacko, Alexander Preuß, Vedran Pavic

Method Summary

Modifier and Type	Method	Description
default AckMode	getAckMode()
default Properties	getConsumerProperties()
default boolean	isBatchListener()

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

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

Method Details

isBatchListener

default boolean isBatchListener()

getConsumerProperties

default Properties getConsumerProperties()

getAckMode

default AckMode getAckMode()