public class StreamListenerContainer extends Object implements MessageListenerContainer, BeanNameAware
| Modifier and Type | Field and Description |
|---|---|
protected Log |
logger |
DEFAULT_PHASE| 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 |
|---|---|
String |
getBeanName()
Return the bean name.
|
String |
getListenerId()
The 'id' attribute of the listener.
|
Object |
getMessageListener()
Get the message listener.
|
StreamMessageConverter |
getStreamConverter()
|
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAutoStartup(boolean autoStart)
Set auto startup.
|
void |
setBeanName(String beanName) |
void |
setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
Customize the consumer builder before it is built.
|
void |
setListenerId(String listenerId)
Set the listener id.
|
void |
setQueueNames(String... queueNames)
Set the queue names.
|
void |
setStreamConverter(StreamMessageConverter messageConverter)
|
void |
setupMessageListener(MessageListener messageListener)
Setup the message listener to use.
|
void |
start() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitafterPropertiesSet, isConsumerBatchEnabled, lazyLoadgetPhase, stopprotected Log logger
public 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(String... queueNames)
MessageListenerContainersetQueueNames in interface MessageListenerContainerqueueNames - the queue names.public StreamMessageConverter getStreamConverter()
public void setStreamConverter(StreamMessageConverter messageConverter)
messageConverter - the converter.public void setConsumerCustomizer(ConsumerCustomizer consumerCustomizer)
consumerCustomizer - the customizer.@Nullable public String getListenerId()
public void setListenerId(String listenerId)
MessageListenerContainersetListenerId in interface MessageListenerContainerlistenerId - the id.public void setBeanName(String beanName)
setBeanName in interface BeanNameAwarepublic void setAutoStartup(boolean autoStart)
MessageListenerContainersetAutoStartup in interface MessageListenerContainerautoStart - true to auto start.public boolean isAutoStartup()
isAutoStartup in interface SmartLifecycle@Nullable public Object getMessageListener()
MessageListenerContainergetMessageListener in interface MessageListenerContainerpublic void setupMessageListener(MessageListener messageListener)
MessageListenerContainerIllegalArgumentException
if that message listener type is not supported.setupMessageListener in interface MessageListenerContainermessageListener - the object to wrapped to the MessageListener.