Package org.springframework.pulsar.config

Class AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>

java.lang.Object
org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory<C,T>
Type Parameters:
C - the AbstractPulsarMessageListenerContainer implementation type.
T - Message payload type.
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, ListenerContainerFactory<PulsarMessageListenerContainer,PulsarListenerEndpoint>, PulsarListenerContainerFactory
Direct Known Subclasses:
ConcurrentPulsarListenerContainerFactory
public abstract class AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T> extends Object implements PulsarListenerContainerFactory, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.ApplicationContextAware
Base PulsarListenerContainerFactory implementation.

  • Field Details

    • logger

      protected final org.springframework.core.log.LogAccessor logger

  • Constructor Details

  • Method Details

    • getConsumerFactory

      protected PulsarConsumerFactory<? super T> getConsumerFactory()

    • getContainerProperties

      public PulsarContainerProperties getContainerProperties()

    • setApplicationContext

      public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
      Specified by:
      setApplicationContext in interface org.springframework.context.ApplicationContextAware
      Throws:
      org.springframework.beans.BeansException

    • setAutoStartup

      public void setAutoStartup(Boolean autoStartup)

    • setPhase

      public void setPhase(int phase)

    • setMessageConverter

      public void setMessageConverter(MessageConverter messageConverter)
      Set the message converter to use if dynamic argument type matching is needed.
      Parameters:
      messageConverter - the converter.

    • setBatchListener

      public void setBatchListener(Boolean batchListener)

    • setApplicationEventPublisher

      public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
      Specified by:
      setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware

    • createListenerContainer

      public C createListenerContainer(PulsarListenerEndpoint 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<C extends AbstractPulsarMessageListenerContainer<T>,T>
      Parameters:
      endpoint - the endpoint to configure
      Returns:
      the created container

    • createContainerInstance

      protected abstract C createContainerInstance(PulsarListenerEndpoint endpoint)

    • initializeContainer

      protected void initializeContainer(C instance, PulsarListenerEndpoint endpoint)