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_PROPERTY
HIGHEST_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, setMessageHandlerMethodFactory
public MultiRabbitListenerAnnotationBeanPostProcessor()
protected Collection<Declarable> processAmqpListener(RabbitListener rabbitListener, Method method, Object bean, String beanName)
processAmqpListener
in class RabbitListenerAnnotationBeanPostProcessor
protected String resolveMultiRabbitAdminName(RabbitListener rabbitListener)
rabbitListener
- The RabbitListener to process the name from.