org.springframework.rabbit.stream.config

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 and Description
StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment) Construct an instance using the provided environment.

Method Summary

Modifier and Type	Method and Description
protected StreamListenerContainer	createContainerInstance() Create an instance of the listener container.
StreamListenerContainer	createListenerContainer(RabbitListenerEndpoint endpoint) Create a MessageListenerContainer for the given RabbitListenerEndpoint.
void	setConsumerCustomizer(Consumer<com.rabbitmq.stream.ConsumerBuilder> consumerCustomizer) Customize the consumer builder before it is built.
void	setContainerCustomizer(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.

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

Constructor Detail

StreamRabbitListenerContainerFactory

public StreamRabbitListenerContainerFactory(com.rabbitmq.stream.Environment environment)

Construct an instance using the provided environment.

Parameters:

environment - the environment.

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(Consumer<com.rabbitmq.stream.ConsumerBuilder> consumerCustomizer)

Customize the consumer builder before it is built.

Parameters:

consumerCustomizer - the customizer.

setContainerCustomizer

public void setContainerCustomizer(ContainerCustomizer<StreamListenerContainer> containerCustomizer)

Set a ContainerCustomizer 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 a MessageListenerContainer for the given RabbitListenerEndpoint.

Specified by:

createListenerContainer in interface RabbitListenerContainerFactory<StreamListenerContainer>

Specified by:

createListenerContainer in class BaseRabbitListenerContainerFactory<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.