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 StreamListenerContainer
createContainerInstance()
Create an instance of the listener container.StreamListenerContainer
createListenerContainer(RabbitListenerEndpoint endpoint)
Create aMessageListenerContainer
for the givenRabbitListenerEndpoint
.void
setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
Customize the consumer builder before it is built.void
setContainerCustomizer(ContainerCustomizer<StreamListenerContainer> containerCustomizer)
Set aContainerCustomizer
that is invoked after a container is created and configured to enable further customization of the container.void
setNativeListener(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, 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 aContainerCustomizer
that 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:RabbitListenerContainerFactory
Create aMessageListenerContainer
for the givenRabbitListenerEndpoint
.- Specified by:
createListenerContainer
in interfaceRabbitListenerContainerFactory<StreamListenerContainer>
- Specified by:
createListenerContainer
in 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.
-
-