public interface RabbitListenerEndpoint
RabbitListenerConfigurer
to register endpoints programmatically.Modifier and Type | Method and Description |
---|---|
default AcknowledgeMode |
getAckMode()
Override the container factory's
AcknowledgeMode . |
Boolean |
getAutoStartup()
Override of the default autoStartup property.
|
String |
getConcurrency() |
String |
getGroup() |
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 String |
getReplyContentType()
Get the reply content type.
|
default ReplyPostProcessor |
getReplyPostProcessor()
Return a
ReplyPostProcessor to post process a reply message before it is
sent. |
default TaskExecutor |
getTaskExecutor()
Get the task executor to use for this endpoint's listener container.
|
default boolean |
isConverterWinsContentType()
Return whether the content type set by a converter prevails or not.
|
default void |
setBatchingStrategy(BatchingStrategy batchingStrategy)
Set a
BatchingStrategy to use when debatching messages. |
default void |
setBatchListener(boolean batchListener)
Called by the container factory with the factory's batchListener property.
|
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.
|
String getId()
RabbitListenerContainerFactory.createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint)
String getGroup()
String getConcurrency()
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.@Nullable default MessageConverter getMessageConverter()
@Nullable default TaskExecutor getTaskExecutor()
default void setBatchListener(boolean batchListener)
batchListener
- the batchListener to set.default void setBatchingStrategy(BatchingStrategy batchingStrategy)
BatchingStrategy
to use when debatching messages.batchingStrategy
- the batching strategy.setBatchListener(boolean)
@Nullable default AcknowledgeMode getAckMode()
AcknowledgeMode
.@Nullable default ReplyPostProcessor getReplyPostProcessor()
ReplyPostProcessor
to post process a reply message before it is
sent.@Nullable default String getReplyContentType()
default boolean isConverterWinsContentType()