public class MultiRabbitListenerAnnotationBeanPostProcessor extends RabbitListenerAnnotationBeanPostProcessor
RabbitListenerAnnotationBeanPostProcessor that indicates the proper
RabbitAdmin bean to be used when processing to the listeners, and also associates it to the
declarables (Exchanges, Queues, and Bindings) returned.
This processing restricts the RabbitAdmin according to the related
configuration, preventing the server from automatic binding non-related structures.
DEFAULT_RABBIT_LISTENER_CONTAINER_FACTORY_BEAN_NAME, RABBIT_EMPTY_STRING_ARGUMENTS_PROPERTYHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| Constructor and Description |
|---|
MultiRabbitListenerAnnotationBeanPostProcessor() |
| Modifier and Type | Method and Description |
|---|---|
protected Collection<Declarable> |
processAmqpListener(RabbitListener rabbitListener,
Method method,
Object bean,
String beanName) |
protected String |
resolveMultiRabbitAdminName(RabbitListener rabbitListener)
Resolves the name of the RabbitAdmin bean based on the RabbitListener, or falls back to
the default RabbitAdmin name provided by MultiRabbit.
|
afterSingletonsInstantiated, assertBeanFactory, getOrder, noBeanFoundMessage, postProcessAfterInitialization, postProcessBeforeInitialization, processListener, resolveExpressionAsString, setBeanClassLoader, setBeanFactory, setCharset, setContainerFactoryBeanName, setEndpointRegistry, setEnvironment, setMessageHandlerMethodFactorypublic MultiRabbitListenerAnnotationBeanPostProcessor()
protected Collection<Declarable> processAmqpListener(RabbitListener rabbitListener, Method method, Object bean, String beanName)
processAmqpListener in class RabbitListenerAnnotationBeanPostProcessorprotected String resolveMultiRabbitAdminName(RabbitListener rabbitListener)
rabbitListener - The RabbitListener to process the name from.