Class StreamRabbitListenerContainerFactory
java.lang.Object
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
- All Implemented Interfaces:
RabbitListenerContainerFactory<StreamListenerContainer>,Aware,ApplicationContextAware
public class StreamRabbitListenerContainerFactory
extends BaseRabbitListenerContainerFactory<StreamListenerContainer>
Factory for StreamListenerContainer.
- Since:
- 2.4
- Author:
- Gary Russell
-
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.Create aMessageListenerContainerfor the givenRabbitListenerEndpoint.voidsetConsumerCustomizer(ConsumerCustomizer consumerCustomizer) Customize the consumer builder before it is built.voidsetContainerCustomizer(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(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
Description copied from interface:RabbitListenerContainerFactoryCreate aMessageListenerContainerfor the givenRabbitListenerEndpoint.- Specified by:
createListenerContainerin interfaceRabbitListenerContainerFactory<StreamListenerContainer>- Specified by:
createListenerContainerin classBaseRabbitListenerContainerFactory<StreamListenerContainer>- Parameters:
endpoint- the endpoint to configure.- Returns:
- the created container.
-
createContainerInstance
Create an instance of the listener container.- Returns:
- the container.
-