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 forPulsarListener
annotations.Create aMessageListenerContainer
for the givenListenerEndpoint
.protected ReactivePulsarConsumerFactory<T>
void
setAutoStartup
(Boolean autoStartup) void
setFluxListener
(Boolean fluxListener) void
setMessageConverter
(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:ListenerContainerFactory
Create aMessageListenerContainer
for the givenListenerEndpoint
. Containers created using this method are added to the listener endpoint registry.- Specified by:
createListenerContainer
in interfaceListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,
ReactivePulsarListenerEndpoint<T>> - Parameters:
endpoint
- the endpoint to configure- Returns:
- the created container
-
createContainer
Description copied from interface:ListenerContainerFactory
Create and configure a container without a listener; used to create containers that are not used forPulsarListener
annotations. Containers created using this method are not added to the listener endpoint registry.- Specified by:
createContainer
in interfaceListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,
ReactivePulsarListenerEndpoint<T>> - Parameters:
topics
- the topics.- Returns:
- the container.
-