public class StreamListenerContainer
extends java.lang.Object
implements org.springframework.amqp.rabbit.listener.MessageListenerContainer, org.springframework.beans.factory.BeanNameAware
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.commons.logging.Log |
logger |
| Constructor and 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.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getBeanName()
Return the bean name.
|
java.lang.String |
getListenerId()
The 'id' attribute of the listener.
|
java.lang.Object |
getMessageListener() |
StreamMessageConverter |
getStreamConverter()
|
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAutoStartup(boolean autoStart) |
void |
setBeanName(java.lang.String beanName) |
void |
setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
Customize the consumer builder before it is built.
|
void |
setListenerId(java.lang.String listenerId) |
void |
setQueueNames(java.lang.String... queueNames) |
void |
setStreamConverter(StreamMessageConverter messageConverter)
|
void |
setupMessageListener(org.springframework.amqp.core.MessageListener messageListener) |
void |
start() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic StreamListenerContainer(com.rabbitmq.stream.Environment environment)
environment - the environment.public StreamListenerContainer(com.rabbitmq.stream.Environment environment,
@Nullable
com.rabbitmq.stream.Codec codec)
environment - the environment.codec - the codec used to create reply messages.public void setQueueNames(java.lang.String... queueNames)
setQueueNames in interface org.springframework.amqp.rabbit.listener.MessageListenerContainerpublic StreamMessageConverter getStreamConverter()
public void setStreamConverter(StreamMessageConverter messageConverter)
messageConverter - the converter.public void setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
consumerCustomizer - the customizer.@Nullable public java.lang.String getListenerId()
public void setListenerId(java.lang.String listenerId)
setListenerId in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer@Nullable public java.lang.String getBeanName()
public void setBeanName(java.lang.String beanName)
setBeanName in interface org.springframework.beans.factory.BeanNameAwarepublic void setAutoStartup(boolean autoStart)
setAutoStartup in interface org.springframework.amqp.rabbit.listener.MessageListenerContainerpublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecycle@Nullable public java.lang.Object getMessageListener()
getMessageListener in interface org.springframework.amqp.rabbit.listener.MessageListenerContainerpublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void setupMessageListener(org.springframework.amqp.core.MessageListener messageListener)
setupMessageListener in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer