Class StreamRabbitListenerContainerFactory

java.lang.Object
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
org.springframework.rabbit.stream.config.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

    Modifier and Type
    Method
    Description
    Create an instance of the listener container.
    createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint)
     
    void
    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, getAdviceChain, getDefaultRequeueRejected, setAdviceChain, 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 Details

    • StreamRabbitListenerContainerFactory

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

    • 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.