Class StreamRabbitListenerContainerFactory
java.lang.Object
org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
- All Implemented Interfaces:
RabbitListenerContainerFactory<StreamListenerContainer>
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.Methods inherited from class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
applyCommonOverrides, getAdviceChain, getDefaultRequeueRejected, setAdviceChain, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, 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.
-
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.
-