public interface RabbitListenerEndpoint
RabbitListenerConfigurer
to register endpoints programmatically.Modifier and Type | Method and Description |
---|---|
java.lang.Boolean |
getAutoStartup()
Override of the default autoStartup property.
|
java.lang.String |
getConcurrency() |
java.lang.String |
getGroup() |
java.lang.String |
getId() |
default MessageConverter |
getMessageConverter()
Used by the container factory to check if this endpoint supports the
preferred way for a container factory to pass a message converter
to the endpoint's adapter.
|
default void |
setMessageConverter(MessageConverter converter)
The preferred way for a container factory to pass a message converter
to the endpoint's adapter.
|
void |
setupListenerContainer(MessageListenerContainer listenerContainer)
Setup the specified message listener container with the model
defined by this endpoint.
|
java.lang.String getId()
RabbitListenerContainerFactory.createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint)
java.lang.String getGroup()
java.lang.String getConcurrency()
java.lang.Boolean getAutoStartup()
void setupListenerContainer(MessageListenerContainer listenerContainer)
This endpoint must provide the requested missing option(s) of
the specified container to make it usable. Usually, this is about
setting the queues
and the messageListener
to
use but an implementation may override any default setting that
was already set.
listenerContainer
- the listener container to configuredefault void setMessageConverter(MessageConverter converter)
converter
- the converter.default MessageConverter getMessageConverter()