Package org.springframework.pulsar.config

Interface ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>

Type Parameters:
C - Container type
E - Endpoint type
All Superinterfaces:
PulsarContainerFactory<C,E>
All Known Subinterfaces:
PulsarReaderContainerFactory
All Known Implementing Classes:
AbstractPulsarReaderContainerFactory, DefaultPulsarReaderContainerFactory
public interface ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>> extends PulsarContainerFactory<C,E>
Base container factory interface for PulsarMessageReaderContainer.
Author:
Soby Chacko, Chris Bono

  • Method Details

    • createReaderContainer

      @Deprecated(since="1.2.0", forRemoval=true) default C createReaderContainer(E endpoint)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 1.2.0 for removal in 1.4.0 in favor of PulsarContainerFactory.createRegisteredContainer(E)
      Create a message reader container for the given endpoint and register the container with the listener endpoint registry.
      Parameters:
      endpoint - reader endpoint
      Returns:
      the created container

    • createReaderContainer

      @Deprecated(since="1.2.0", forRemoval=true) default C createReaderContainer(String... topics)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 1.2.0 for removal in 1.4.0 in favor of PulsarContainerFactory.createContainer(java.lang.String...)
      Create a message reader container for the given endpoint.
      Parameters:
      topics - the topics to read from
      Returns:
      the created container