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, wait
afterPropertiesSet, isConsumerBatchEnabled, lazyLoad
getPhase, stop
protected 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)
MessageListenerContainer
setQueueNames
in interface MessageListenerContainer
queueNames
- 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)
MessageListenerContainer
setListenerId
in interface MessageListenerContainer
listenerId
- the id.public void setBeanName(String beanName)
setBeanName
in interface BeanNameAware
public void setAutoStartup(boolean autoStart)
MessageListenerContainer
setAutoStartup
in interface MessageListenerContainer
autoStart
- true to auto start.public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
@Nullable public Object getMessageListener()
MessageListenerContainer
getMessageListener
in interface MessageListenerContainer
public void setupMessageListener(MessageListener messageListener)
MessageListenerContainer
IllegalArgumentException
if that message listener type is not supported.setupMessageListener
in interface MessageListenerContainer
messageListener
- the object
to wrapped to the MessageListener
.