Class DefaultReactivePulsarListenerContainerFactory<T>
java.lang.Object
org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory<T>
- Type Parameters:
T- Message payload type.
- All Implemented Interfaces:
ListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,,ReactivePulsarListenerEndpoint<T>> ReactivePulsarListenerContainerFactory<T>
public class DefaultReactivePulsarListenerContainerFactory<T>
extends Object
implements ReactivePulsarListenerContainerFactory<T>
Concrete implementation for
ReactivePulsarListenerContainerFactory.- Author:
- Christophe Bornet
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionDefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T> consumerFactory, ReactivePulsarContainerProperties<T> containerProperties) -
Method Summary
Modifier and TypeMethodDescriptioncreateContainer(String... topics) Create and configure a container without a listener; used to create containers that are not used forPulsarListenerannotations.Create aMessageListenerContainerfor the givenListenerEndpoint.protected ReactivePulsarConsumerFactory<T>voidsetAutoStartup(Boolean autoStartup) voidsetFluxListener(Boolean fluxListener) voidsetMessageConverter(MessageConverter messageConverter) Set the message converter to use if dynamic argument type matching is needed.
-
Field Details
-
logger
-
-
Constructor Details
-
DefaultReactivePulsarListenerContainerFactory
public DefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T> consumerFactory, ReactivePulsarContainerProperties<T> containerProperties)
-
-
Method Details
-
getConsumerFactory
-
getContainerProperties
-
setAutoStartup
-
setMessageConverter
Set the message converter to use if dynamic argument type matching is needed.- Parameters:
messageConverter- the converter.
-
setFluxListener
-
createContainerInstance
public DefaultReactivePulsarMessageListenerContainer<T> createContainerInstance(ReactivePulsarListenerEndpoint<T> endpoint) -
createListenerContainer
public DefaultReactivePulsarMessageListenerContainer<T> createListenerContainer(ReactivePulsarListenerEndpoint<T> endpoint) Description copied from interface:ListenerContainerFactoryCreate aMessageListenerContainerfor the givenListenerEndpoint. Containers created using this method are added to the listener endpoint registry.- Specified by:
createListenerContainerin interfaceListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>> - Parameters:
endpoint- the endpoint to configure- Returns:
- the created container
-
createContainer
Description copied from interface:ListenerContainerFactoryCreate 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.- Specified by:
createContainerin interfaceListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>> - Parameters:
topics- the topics.- Returns:
- the container.
-