public class MultiRabbitListenerAnnotationBeanPostProcessor extends RabbitListenerAnnotationBeanPostProcessor
RabbitListenerAnnotationBeanPostProcessor
that associates the
proper RabbitAdmin to the beans of Exchanges, Queues, and Bindings after they are
created.
This processing restricts the RabbitAdmin
according to the related
configuration, preventing the server from automatic binding non-related structures.
Modifier and Type | Field and Description |
---|---|
static String |
CONNECTION_FACTORY_BEAN_NAME |
static String |
CONNECTION_FACTORY_CREATOR_BEAN_NAME |
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 static final String CONNECTION_FACTORY_BEAN_NAME
public static final String CONNECTION_FACTORY_CREATOR_BEAN_NAME
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.