public class StreamRabbitListenerContainerFactory extends org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>
| Constructor and Description |
|---|
StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment)
Construct an instance using the provided environment.
|
| Modifier and Type | Method and Description |
|---|---|
protected StreamListenerContainer |
createContainerInstance()
Create an instance of the listener container.
|
StreamListenerContainer |
createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint) |
void |
setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
Customize the consumer builder before it is built.
|
void |
setContainerCustomizer(org.springframework.amqp.rabbit.config.ContainerCustomizer<StreamListenerContainer> containerCustomizer)
Set a
ContainerCustomizer 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.
|
applyCommonOverrides, getDefaultRequeueRejected, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setReplyRecoveryCallback, setRetryTemplatepublic StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment)
environment - the environment.public void setNativeListener(boolean nativeListener)
nativeListener - true for native listeners.public void setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
consumerCustomizer - the customizer.public void setContainerCustomizer(org.springframework.amqp.rabbit.config.ContainerCustomizer<StreamListenerContainer> containerCustomizer)
ContainerCustomizer that is invoked after a container is created and
configured to enable further customization of the container.containerCustomizer - the customizer.public StreamListenerContainer createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint endpoint)
createListenerContainer in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory<StreamListenerContainer>createListenerContainer in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory<StreamListenerContainer>protected StreamListenerContainer createContainerInstance()