Class StreamRabbitListenerContainerFactory

  • All Implemented Interfaces:
    org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<StreamListenerContainer>

    public class StreamRabbitListenerContainerFactory
    extends org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
    Factory for StreamListenerContainer.
    Since:
    2.4
    • Constructor Summary

      Constructors 
      Constructor Description
      StreamRabbitListenerContainerFactory​(com.rabbitmq.stream.Environment environment)
      Construct an instance using the provided environment.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected StreamListenerContainer createContainerInstance()
      Create an instance of the listener container.
      StreamListenerContainer createListenerContainer​(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint)  
      void setConsumerCustomizer​(ConsumerCustomizer consumerCustomizer)
      Customize the consumer builder before it is built.
      void setContainerCustomizer​(org.springframework.amqp.rabbit.config.ContainerCustomizer<StreamListenerContainer> containerCustomizer)
      Set a ContainerCustomizer that is invoked after a container is created and configured to enable further customization of the container.
      void setNativeListener​(boolean nativeListener)
      Set to true to create a container supporting a native RabbitMQ Stream message.
      • Methods inherited from class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory

        applyCommonOverrides, getDefaultRequeueRejected, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setReplyRecoveryCallback, setRetryTemplate
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory

        createListenerContainer
    • Constructor Detail

      • StreamRabbitListenerContainerFactory

        public StreamRabbitListenerContainerFactory​(com.rabbitmq.stream.Environment environment)
        Construct an instance using the provided environment.
        Parameters:
        environment - the environment.
    • Method Detail

      • setNativeListener

        public void setNativeListener​(boolean nativeListener)
        Set to true to create a container supporting a native RabbitMQ Stream message.
        Parameters:
        nativeListener - true for native listeners.
      • setConsumerCustomizer

        public void setConsumerCustomizer​(ConsumerCustomizer consumerCustomizer)
        Customize the consumer builder before it is built.
        Parameters:
        consumerCustomizer - the customizer.
      • setContainerCustomizer

        public void setContainerCustomizer​(org.springframework.amqp.rabbit.config.ContainerCustomizer<StreamListenerContainer> containerCustomizer)
        Set a ContainerCustomizer that is invoked after a container is created and configured to enable further customization of the container.
        Parameters:
        containerCustomizer - the customizer.
      • createListenerContainer

        public StreamListenerContainer createListenerContainer​(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint)
        Specified by:
        createListenerContainer in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<StreamListenerContainer>
        Specified by:
        createListenerContainer in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
      • createContainerInstance

        protected StreamListenerContainer createContainerInstance()
        Create an instance of the listener container.
        Returns:
        the container.