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>, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class StreamRabbitListenerContainerFactory extends org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
Factory for StreamListenerContainer.
Since:
2.4
  • 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.
    • setStreamListenerObservationConvention

      public void setStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention)
      Set a RabbitStreamListenerObservationConvention that is used when receiving native stream messages.
      Parameters:
      streamListenerObservationConvention - the convention.
      Since:
      3.0.5
    • 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.