Class PulsarListenerEndpointAdapter
java.lang.Object
org.springframework.pulsar.config.PulsarListenerEndpointAdapter
- All Implemented Interfaces:
ListenerEndpoint<PulsarMessageListenerContainer>
,PulsarListenerEndpoint
@Deprecated(forRemoval=true)
public class PulsarListenerEndpointAdapter
extends Object
implements PulsarListenerEndpoint
Deprecated, for removal: This API element is subject to removal in a future version.
Adapter to avoid having to implement all methods.
- Author:
- Soby Chacko, Alexander Preuß
-
Constructor Summary
ConstructorsConstructorDescriptionDeprecated, for removal: This API element is subject to removal in a future version. -
Method Summary
Modifier and TypeMethodDescriptionDeprecated, for removal: This API element is subject to removal in a future version.Deprecated, for removal: This API element is subject to removal in a future version.Return the autoStartup for this endpoint's container.Deprecated, for removal: This API element is subject to removal in a future version.Return the concurrency for this endpoint's container.Deprecated, for removal: This API element is subject to removal in a future version.getId()
Deprecated, for removal: This API element is subject to removal in a future version.Return the id of this endpoint.org.apache.pulsar.common.schema.SchemaType
Deprecated, for removal: This API element is subject to removal in a future version.Return the schema type for this endpoint's container.Deprecated, for removal: This API element is subject to removal in a future version.Return the subscription name for this endpoint's container.org.apache.pulsar.client.api.SubscriptionType
Deprecated, for removal: This API element is subject to removal in a future version.Return the subscription type for this endpoint's container.Deprecated, for removal: This API element is subject to removal in a future version.Return the topic pattern for this endpoint's container.Deprecated, for removal: This API element is subject to removal in a future version.Return the topics for this endpoint's container.boolean
Deprecated, for removal: This API element is subject to removal in a future version.void
setupListenerContainer
(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter) Deprecated, for removal: This API element is subject to removal in a future version.Setup the specified message listener container with the model defined by this endpoint.
-
Constructor Details
-
PulsarListenerEndpointAdapter
public PulsarListenerEndpointAdapter()Deprecated, for removal: This API element is subject to removal in a future version.
-
-
Method Details
-
getId
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the id of this endpoint.- Specified by:
getId
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the id of this endpoint. The id can be further qualified when the endpoint is resolved against its actual listener container.
- See Also:
-
getSubscriptionName
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the subscription name for this endpoint's container.- Specified by:
getSubscriptionName
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the subscription name.
-
getSubscriptionType
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the subscription type for this endpoint's container.- Specified by:
getSubscriptionType
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the subscription type.
-
getTopics
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the topics for this endpoint's container.- Specified by:
getTopics
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the topics.
-
getTopicPattern
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the topic pattern for this endpoint's container.- Specified by:
getTopicPattern
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the topic pattern.
-
getAutoStartup
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the autoStartup for this endpoint's container.- Specified by:
getAutoStartup
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the autoStartup.
-
setupListenerContainer
public void setupListenerContainer(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter) Deprecated, for removal: This API element is subject to removal in a future version.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 themessageListener
to use but an implementation may override any default setting that was already set.- Specified by:
setupListenerContainer
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Parameters:
listenerContainer
- the listener container to configuremessageConverter
- the message converter - can be null
-
isBatchListener
public boolean isBatchListener()Deprecated, for removal: This API element is subject to removal in a future version.- Specified by:
isBatchListener
in interfacePulsarListenerEndpoint
-
getSchemaType
public org.apache.pulsar.common.schema.SchemaType getSchemaType()Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the schema type for this endpoint's container.- Specified by:
getSchemaType
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the schema type.
-
getConsumerProperties
Deprecated, for removal: This API element is subject to removal in a future version.- Specified by:
getConsumerProperties
in interfacePulsarListenerEndpoint
-
getConcurrency
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:ListenerEndpoint
Return the concurrency for this endpoint's container.- Specified by:
getConcurrency
in interfaceListenerEndpoint<PulsarMessageListenerContainer>
- Returns:
- the concurrency.
-
getAckMode
Deprecated, for removal: This API element is subject to removal in a future version.- Specified by:
getAckMode
in interfacePulsarListenerEndpoint
-
PulsarListenerEndpoint