Package org.springframework.pulsar.reactive.config

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

Modifier and Type	Field	Description
protected final LogAccessor	logger

Constructor Summary

Constructors

Constructor	Description
DefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T> consumerFactory, ReactivePulsarContainerProperties<T> containerProperties)

Method Summary

Modifier and Type	Method	Description
DefaultReactivePulsarMessageListenerContainer<T>	createContainer(String... topics)	Create and configure a container without a listener; used to create containers that are not used for PulsarListener annotations.
DefaultReactivePulsarMessageListenerContainer<T>	createContainerInstance(ReactivePulsarListenerEndpoint<T> endpoint)
DefaultReactivePulsarMessageListenerContainer<T>	createListenerContainer(ReactivePulsarListenerEndpoint<T> endpoint)	Create a MessageListenerContainer for the given ListenerEndpoint.
protected ReactivePulsarConsumerFactory<T>	getConsumerFactory()
ReactivePulsarContainerProperties<T>	getContainerProperties()
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

protected final LogAccessor logger

Constructor Details

DefaultReactivePulsarListenerContainerFactory

public DefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T> consumerFactory,
 ReactivePulsarContainerProperties<T> containerProperties)

Method Details

getConsumerFactory

protected ReactivePulsarConsumerFactory<T> getConsumerFactory()

getContainerProperties

public ReactivePulsarContainerProperties<T> getContainerProperties()

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Set the message converter to use if dynamic argument type matching is needed.

Parameters:

messageConverter - the converter.

setFluxListener

public void setFluxListener(Boolean fluxListener)

createContainerInstance

public DefaultReactivePulsarMessageListenerContainer<T> createContainerInstance(ReactivePulsarListenerEndpoint<T> endpoint)

createListenerContainer

public DefaultReactivePulsarMessageListenerContainer<T> createListenerContainer(ReactivePulsarListenerEndpoint<T> endpoint)

Description copied from interface: ListenerContainerFactory

Create a MessageListenerContainer for the given ListenerEndpoint. Containers created using this method are added to the listener endpoint registry.

Specified by:

createListenerContainer in interface ListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>>

Parameters:

endpoint - the endpoint to configure

Returns:

the created container

createContainer

public DefaultReactivePulsarMessageListenerContainer<T> createContainer(String... topics)

Description copied from interface: ListenerContainerFactory

Create and configure a container without a listener; used to create containers that are not used for PulsarListener annotations. Containers created using this method are not added to the listener endpoint registry.

Specified by:

createContainer in interface ListenerContainerFactory<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>>

Parameters:

topics - the topics.

Returns:

the container.