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>
@Deprecated(forRemoval=true) public class ReactivePulsarListenerEndpointAdapter<T> extends Object implements ReactivePulsarListenerEndpoint<T>
Deprecated, for removal: This API element is subject to removal in a future version.
for removal in favor of ReactivePulsarListenerEndpoint
Adapter to avoid having to implement all methods.
Author:
Christophe Bornet

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactivePulsarListenerEndpointAdapter()
    Deprecated, for removal: This API element is subject to removal in a future version.
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Boolean
    getAutoStartup()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the autoStartup for this endpoint's container.
    Integer
    getConcurrency()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the concurrency for this endpoint's container.
    String
    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
    getSchemaType()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the schema type for this endpoint's container.
    String
    getSubscriptionName()
    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
    getSubscriptionType()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the subscription type for this endpoint's container.
    String
    getTopicPattern()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the topic pattern for this endpoint's container.
    List<String>
    getTopics()
    Deprecated, for removal: This API element is subject to removal in a future version.
    Return the topics for this endpoint's container.
    Boolean
    getUseKeyOrderedProcessing()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    boolean
    isFluxListener()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    setupListenerContainer(ReactivePulsarMessageListenerContainer<T> 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.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactivePulsarListenerEndpointAdapter

      public ReactivePulsarListenerEndpointAdapter()
      Deprecated, for removal: This API element is subject to removal in a future version.

  • Method Details

    • getId

      public String 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 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:

    • getSubscriptionName

      public String 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 interface ListenerEndpoint<T>
      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 interface ListenerEndpoint<T>
      Returns:
      the subscription type.

    • getTopics

      public List<String> 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 interface ListenerEndpoint<T>
      Returns:
      the topics.

    • getTopicPattern

      public String 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 interface ListenerEndpoint<T>
      Returns:
      the topic pattern.

    • getAutoStartup

      public Boolean 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 interface ListenerEndpoint<T>
      Returns:
      the autoStartup.

    • setupListenerContainer

      public void setupListenerContainer(ReactivePulsarMessageListenerContainer<T> 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 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()
      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 interface ListenerEndpoint<T>
      Returns:
      the schema type.

    • getConcurrency

      @Nullable public Integer 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 interface ListenerEndpoint<T>
      Returns:
      the concurrency.

    • isFluxListener

      public boolean isFluxListener()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      isFluxListener in interface ReactivePulsarListenerEndpoint<T>

    • getUseKeyOrderedProcessing

      public Boolean getUseKeyOrderedProcessing()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      getUseKeyOrderedProcessing in interface ReactivePulsarListenerEndpoint<T>