Interface ListenerContainerFactory<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>
- Type Parameters:
C- message listener container type.E- listener endpoint type.
- All Known Subinterfaces:
PulsarListenerContainerFactory,ReactivePulsarListenerContainerFactory<T>
- All Known Implementing Classes:
AbstractPulsarListenerContainerFactory,ConcurrentPulsarListenerContainerFactory,DefaultReactivePulsarListenerContainerFactory
public interface ListenerContainerFactory<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>
Factory for Pulsar message listener containers.
- Author:
- Soby Chacko, Christophe Bornet
-
Method Summary
Modifier and TypeMethodDescriptioncreateContainer(String... topics) Create and configure a container without a listener; used to create containers that are not used forPulsarListenerannotations.createListenerContainer(E endpoint) Create aMessageListenerContainerfor the givenListenerEndpoint.
-
Method Details
-
createListenerContainer
Create aMessageListenerContainerfor the givenListenerEndpoint. Containers created using this method are added to the listener endpoint registry.- Parameters:
endpoint- the endpoint to configure- Returns:
- the created container
-
createContainer
Create and configure a container without a listener; used to create containers that are not used forPulsarListenerannotations. Containers created using this method are not added to the listener endpoint registry.- Parameters:
topics- the topics.- Returns:
- the container.
-