Package org.springframework.pulsar.config

Class ConcurrentPulsarListenerContainerFactory<T>

java.lang.Object

org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory<ConcurrentPulsarMessageListenerContainer<T>,T>

org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory<T>

Type Parameters:

T - message type in the listener.

All Implemented Interfaces:

Aware, ApplicationContextAware, ApplicationEventPublisherAware, ListenerContainerFactory<PulsarMessageListenerContainer,PulsarListenerEndpoint>, PulsarListenerContainerFactory

public class ConcurrentPulsarListenerContainerFactory<T>
extends AbstractPulsarListenerContainerFactory<ConcurrentPulsarMessageListenerContainer<T>,T>

Concrete implementation for PulsarListenerContainerFactory.

Author:

Soby Chacko, Chris Bono, Alexander Preuß

Field Summary

Fields inherited from class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

logger

Constructor Summary

Constructors

Constructor	Description
ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory, PulsarContainerProperties containerProperties)

Method Summary

Modifier and Type	Method	Description
ConcurrentPulsarMessageListenerContainer<T>	createContainer(String... topics)	Create and configure a container without a listener; used to create containers that are not used for PulsarListener annotations.
protected ConcurrentPulsarMessageListenerContainer<T>	createContainerInstance(PulsarListenerEndpoint endpoint)
protected void	initializeContainer(ConcurrentPulsarMessageListenerContainer<T> instance, PulsarListenerEndpoint endpoint)
void	setConcurrency(Integer concurrency)	Specify the container concurrency.

Methods inherited from class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

createListenerContainer, getConsumerFactory, getContainerProperties, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchListener, setMessageConverter, setPhase

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentPulsarListenerContainerFactory

public ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory,
 PulsarContainerProperties containerProperties)

Method Details

setConcurrency

public void setConcurrency(Integer concurrency)

Specify the container concurrency.

Parameters:

concurrency - the number of consumers to create.

createContainer

public ConcurrentPulsarMessageListenerContainer<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.

Parameters:

topics - the topics.

Returns:

the container.

createContainerInstance

protected ConcurrentPulsarMessageListenerContainer<T> createContainerInstance(PulsarListenerEndpoint endpoint)

Specified by:

createContainerInstance in class AbstractPulsarListenerContainerFactory<ConcurrentPulsarMessageListenerContainer<T>,T>

initializeContainer

protected void initializeContainer(ConcurrentPulsarMessageListenerContainer<T> instance,
 PulsarListenerEndpoint endpoint)

Overrides:

initializeContainer in class AbstractPulsarListenerContainerFactory<ConcurrentPulsarMessageListenerContainer<T>,T>