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

Method Summary

Modifier and Type	Method	Description
protected StreamListenerContainer	createContainerInstance()	Create an instance of the listener container.
StreamListenerContainer	createListenerContainer(RabbitListenerEndpoint endpoint)	Create a MessageListenerContainer for the given RabbitListenerEndpoint.
void	setConsumerCustomizer(ConsumerCustomizer 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, 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

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(ConsumerCustomizer 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.