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 Summary
ConstructorsConstructorDescriptionStreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment) Construct an instance using the provided environment. -
Method Summary
Modifier and TypeMethodDescriptionprotected StreamListenerContainerCreate an instance of the listener container.createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint) voidsetConsumerCustomizer(ConsumerCustomizer consumerCustomizer) Customize the consumer builder before it is built.voidsetContainerCustomizer(org.springframework.amqp.rabbit.config.ContainerCustomizer<StreamListenerContainer> containerCustomizer) Set aContainerCustomizerthat is invoked after a container is created and configured to enable further customization of the container.voidsetNativeListener(boolean nativeListener) Set to true to create a container supporting a native RabbitMQ Stream message.voidsetStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention) Set aRabbitStreamListenerObservationConventionthat is used when receiving native stream messages.Methods inherited from class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
applyCommonOverrides, getAdviceChain, getApplicationContext, getDefaultRequeueRejected, getMicrometerEnabled, getObservationEnabled, setAdviceChain, setApplicationContext, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setMicrometerEnabled, setObservationEnabled, setReplyPostProcessorProvider, setReplyRecoveryCallback, setRetryTemplateMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods 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
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 aContainerCustomizerthat 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 aRabbitStreamListenerObservationConventionthat 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:
createListenerContainerin interfaceorg.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<StreamListenerContainer>- Specified by:
createListenerContainerin classorg.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
-
createContainerInstance
Create an instance of the listener container.- Returns:
- the container.
-