Package org.springframework.pulsar.config

Interface PulsarContainerFactory<C,E>

Type Parameters:
C - message container
E - message listener endpoint
All Known Subinterfaces:
ListenerContainerFactory<C,E>, PulsarListenerContainerFactory, PulsarReaderContainerFactory, ReactivePulsarListenerContainerFactory<T>, ReaderContainerFactory<C,E>
All Known Implementing Classes:
AbstractPulsarListenerContainerFactory, AbstractPulsarReaderContainerFactory, ConcurrentPulsarListenerContainerFactory, DefaultPulsarReaderContainerFactory, DefaultReactivePulsarListenerContainerFactory
public interface PulsarContainerFactory<C,E>
Factory for Pulsar message listener containers.
Since:
1.2.0
Author:
Chris Bono

  • Method Summary

    Modifier and Type
    Method
    Description
    C
    createContainer(String... topics)
    Create and configure a container without a listener.
    C
    createRegisteredContainer(E endpoint)
    Create a message listener container for the given endpoint.

  • Method Details

    • createRegisteredContainer

      C createRegisteredContainer(E endpoint)
      Create a message listener container for the given endpoint. Containers created using this method are added to the listener endpoint registry.
      Parameters:
      endpoint - the endpoint to configure
      Returns:
      the created container

    • createContainer

      C createContainer(String... topics)
      Create and configure a container without a listener. Containers created using this method are not added to the listener endpoint registry.
      Parameters:
      topics - the topics.
      Returns:
      the container.