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
Constructors Constructor Description StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment)Construct an instance using the provided environment.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected StreamListenerContainercreateContainerInstance()Create an instance of the listener container.StreamListenerContainercreateListenerContainer(RabbitListenerEndpoint endpoint)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, getDefaultRequeueRejected, 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
-
-
-
-
Method Detail
-
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(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
public StreamListenerContainer createListenerContainer(RabbitListenerEndpoint endpoint)
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
protected StreamListenerContainer createContainerInstance()
Create an instance of the listener container.- Returns:
- the container.
-
-