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>, Aware, ApplicationContextAware

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.
void	setStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention)	Set a RabbitStreamListenerObservationConvention that is used when receiving native stream messages.

Methods inherited from class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory

applyCommonOverrides, getAdviceChain, getApplicationContext, getDefaultRequeueRejected, getMicrometerEnabled, getObservationEnabled, setAdviceChain, setApplicationContext, setBeforeSendReplyPostProcessors, setDefaultRequeueRejected, setMicrometerEnabled, setObservationEnabled, setReplyPostProcessorProvider, 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 Details

StreamRabbitListenerContainerFactory

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

Construct an instance using the provided environment.

Parameters:

environment - the environment.

Method Details

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.

setStreamListenerObservationConvention

public void setStreamListenerObservationConvention(RabbitStreamListenerObservationConvention streamListenerObservationConvention)

Set a RabbitStreamListenerObservationConvention that is used when receiving native stream messages.

Parameters:

streamListenerObservationConvention - the convention.

Since:

3.0.5

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.