Package org.springframework.pulsar.reactive.config

Class ReactivePulsarListenerEndpointAdapter<T>

java.lang.Object

org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointAdapter<T>

Type Parameters:

T - Message payload type.

All Implemented Interfaces:

ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>, ReactivePulsarListenerEndpoint<T>

public class ReactivePulsarListenerEndpointAdapter<T>
extends Object
implements ReactivePulsarListenerEndpoint<T>

Adapter to avoid having to implement all methods.

Author:

Christophe Bornet

Constructor Summary

Constructors

Constructor	Description
ReactivePulsarListenerEndpointAdapter()

Method Summary

Modifier and Type	Method	Description
Boolean	getAutoStartup()	Return the autoStartup for this endpoint's container.
Integer	getConcurrency()	Return the concurrency for this endpoint's container.
String	getId()	Return the id of this endpoint.
org.apache.pulsar.common.schema.SchemaType	getSchemaType()	Return the schema type for this endpoint's container.
String	getSubscriptionName()	Return the subscription name for this endpoint's container.
org.apache.pulsar.client.api.SubscriptionType	getSubscriptionType()	Return the subscription type for this endpoint's container.
String	getTopicPattern()	Return the topic pattern for this endpoint's container.
List<String>	getTopics()	Return the topics for this endpoint's container.
Boolean	getUseKeyOrderedProcessing()
boolean	isFluxListener()
void	setupListenerContainer(ReactivePulsarMessageListenerContainer<T> listenerContainer, MessageConverter messageConverter)	Setup the specified message listener container with the model defined by this endpoint.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactivePulsarListenerEndpointAdapter

public ReactivePulsarListenerEndpointAdapter()

Method Details

getId

public String getId()

Description copied from interface: ListenerEndpoint

Return the id of this endpoint.

Specified by:

getId in interface ListenerEndpoint<T>

Returns:

the id of this endpoint. The id can be further qualified when the endpoint is resolved against its actual listener container.

See Also:

• ListenerContainerFactory.createListenerContainer(E)

getSubscriptionName

public String getSubscriptionName()

Description copied from interface: ListenerEndpoint

Return the subscription name for this endpoint's container.

Specified by:

getSubscriptionName in interface ListenerEndpoint<T>

Returns:

the subscription name.

getSubscriptionType

public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()

Description copied from interface: ListenerEndpoint

Return the subscription type for this endpoint's container.

Specified by:

getSubscriptionType in interface ListenerEndpoint<T>

Returns:

the subscription type.

getTopics

public List<String> getTopics()

Description copied from interface: ListenerEndpoint

Return the topics for this endpoint's container.

Specified by:

getTopics in interface ListenerEndpoint<T>

Returns:

the topics.

getTopicPattern

public String getTopicPattern()

Description copied from interface: ListenerEndpoint

Return the topic pattern for this endpoint's container.

Specified by:

getTopicPattern in interface ListenerEndpoint<T>

Returns:

the topic pattern.

getAutoStartup

public Boolean getAutoStartup()

Description copied from interface: ListenerEndpoint

Return the autoStartup for this endpoint's container.

Specified by:

getAutoStartup in interface ListenerEndpoint<T>

Returns:

the autoStartup.

setupListenerContainer

public void setupListenerContainer(ReactivePulsarMessageListenerContainer<T> listenerContainer,
 MessageConverter messageConverter)

Description copied from interface: ListenerEndpoint

Setup the specified message listener container with the model defined by this endpoint.

This endpoint must provide the requested missing option(s) of the specified container to make it usable. Usually, this is about setting the queues and the messageListener to use but an implementation may override any default setting that was already set.

Specified by:

setupListenerContainer in interface ListenerEndpoint<T>

Parameters:

listenerContainer - the listener container to configure

messageConverter - the message converter - can be null

getSchemaType

public org.apache.pulsar.common.schema.SchemaType getSchemaType()

Description copied from interface: ListenerEndpoint

Return the schema type for this endpoint's container.

Specified by:

getSchemaType in interface ListenerEndpoint<T>

Returns:

the schema type.

getConcurrency

@Nullable
public Integer getConcurrency()

Description copied from interface: ListenerEndpoint

Return the concurrency for this endpoint's container.

Specified by:

getConcurrency in interface ListenerEndpoint<T>

Returns:

the concurrency.

isFluxListener

public boolean isFluxListener()

Specified by:

isFluxListener in interface ReactivePulsarListenerEndpoint<T>

getUseKeyOrderedProcessing

public Boolean getUseKeyOrderedProcessing()

Specified by:

getUseKeyOrderedProcessing in interface ReactivePulsarListenerEndpoint<T>