Class StreamListenerContainer
- java.lang.Object
-
- org.springframework.rabbit.stream.listener.StreamListenerContainer
-
- All Implemented Interfaces:
org.springframework.amqp.rabbit.listener.MessageListenerContainer,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class StreamListenerContainer extends java.lang.Object implements org.springframework.amqp.rabbit.listener.MessageListenerContainer, org.springframework.beans.factory.BeanNameAwareA listener container for RabbitMQ Streams.- Since:
- 2.4
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.commons.logging.Loglogger
-
Constructor Summary
Constructors Constructor Description StreamListenerContainer(com.rabbitmq.stream.Environment environment)Construct an instance using the provided environment.StreamListenerContainer(com.rabbitmq.stream.Environment environment, com.rabbitmq.stream.Codec codec)Construct an instance using the provided environment and codec.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.StringgetBeanName()Return the bean name.java.lang.StringgetListenerId()The 'id' attribute of the listener.java.lang.ObjectgetMessageListener()StreamMessageConvertergetStreamConverter()booleanisAutoStartup()booleanisRunning()voidsetAutoStartup(boolean autoStart)voidsetBeanName(java.lang.String beanName)voidsetConsumerCustomizer(ConsumerCustomizer consumerCustomizer)Customize the consumer builder before it is built.voidsetListenerId(java.lang.String listenerId)voidsetQueueNames(java.lang.String... queueNames)voidsetStreamConverter(StreamMessageConverter messageConverter)voidsetupMessageListener(org.springframework.amqp.core.MessageListener messageListener)voidstart()voidstop()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Constructor Detail
-
StreamListenerContainer
public StreamListenerContainer(com.rabbitmq.stream.Environment environment)
Construct an instance using the provided environment.- Parameters:
environment- the environment.
-
StreamListenerContainer
public StreamListenerContainer(com.rabbitmq.stream.Environment environment, @Nullable com.rabbitmq.stream.Codec codec)Construct an instance using the provided environment and codec.- Parameters:
environment- the environment.codec- the codec used to create reply messages.
-
-
Method Detail
-
setQueueNames
public void setQueueNames(java.lang.String... queueNames)
- Specified by:
setQueueNamesin interfaceorg.springframework.amqp.rabbit.listener.MessageListenerContainer
-
getStreamConverter
public StreamMessageConverter getStreamConverter()
- Returns:
- the converter.
-
setStreamConverter
public void setStreamConverter(StreamMessageConverter messageConverter)
- Parameters:
messageConverter- the converter.
-
setConsumerCustomizer
public void setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
Customize the consumer builder before it is built.- Parameters:
consumerCustomizer- the customizer.
-
getListenerId
@Nullable public java.lang.String getListenerId()
The 'id' attribute of the listener.- Returns:
- the id (or the container bean name if no id set).
-
setListenerId
public void setListenerId(java.lang.String listenerId)
- Specified by:
setListenerIdin interfaceorg.springframework.amqp.rabbit.listener.MessageListenerContainer
-
getBeanName
@Nullable public java.lang.String getBeanName()
Return the bean name.- Returns:
- the bean name.
-
setBeanName
public void setBeanName(java.lang.String beanName)
- Specified by:
setBeanNamein interfaceorg.springframework.beans.factory.BeanNameAware
-
setAutoStartup
public void setAutoStartup(boolean autoStart)
- Specified by:
setAutoStartupin interfaceorg.springframework.amqp.rabbit.listener.MessageListenerContainer
-
isAutoStartup
public boolean isAutoStartup()
- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
getMessageListener
@Nullable public java.lang.Object getMessageListener()
- Specified by:
getMessageListenerin interfaceorg.springframework.amqp.rabbit.listener.MessageListenerContainer
-
isRunning
public boolean isRunning()
- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
start
public void start()
- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()
- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
setupMessageListener
public void setupMessageListener(org.springframework.amqp.core.MessageListener messageListener)
- Specified by:
setupMessageListenerin interfaceorg.springframework.amqp.rabbit.listener.MessageListenerContainer
-
-