java Spring AMQP有两个监听器，只有一个监听器工作

Question

我有一个FanouteExchange，它有两个队列。每个队列有一个侦听器，当我为每个ListenerAdapter创建两个SimpleMessageListenerContainer时，只有第一个有效

为了更好地解释，我将代码留在这里：

public static final String BROADCAST_PERSISTENCE_QUEUE = "persistence.rabbit.queue";
public static final String BROADCAST_WEBAPP_QUEUE = "webapp.rabbit.queue";

@Bean
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory(
            "localhost");
    return connectionFactory;
}

@Bean
public AmqpAdmin amqpAdmin() {
    return new RabbitAdmin(connectionFactory());
}

@Bean
public Queue persistenceQueue() {
    return new Queue(BROADCAST_PERSISTENCE_QUEUE);
}

@Bean
public Queue webAppQueue() {
    return new Queue(BROADCAST_WEBAPP_QUEUE);
}

@Bean
public RabbitTemplate rabbitTemplate() {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
    return rabbitTemplate;
}

@Bean
public FanoutExchange trashRouteExchange() {
    FanoutExchange exchange = new FanoutExchange("trashroute");
    return exchange;
}

@Bean
public Binding trashRouteBinding() {
    return BindingBuilder.bind(persistenceQueue()).to(trashRouteExchange());
}

@Bean
public Binding webAppBinding() {
    return BindingBuilder.bind(webAppQueue()).to(trashRouteExchange());
}

@Bean
MessageListenerAdapter persistenceListenerAdapter(PersistenceListener persistenceListener) {
    return new MessageListenerAdapter(persistenceListener, "receiveMessage");
}

@Bean
SimpleMessageListenerContainer persistenceListenerContainer(
        ConnectionFactory connectionFactory,
        @Qualifier("persistenceListenerAdapter") MessageListenerAdapter persistenceListenerAdapter) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueues(persistenceQueue(), webAppQueue());
    container.setMessageListener(persistenceListenerAdapter);
    return container;
}

@Bean
MessageListenerAdapter webAppListenerAdapter(WebAppListener webAppListener) {
    return new MessageListenerAdapter(webAppListener, "receiveMessage");
}


@Bean
SimpleMessageListenerContainer webAppListenerContainer(
        ConnectionFactory connectionFactory,
        @Qualifier("webAppListenerAdapter") MessageListenerAdapter webAppListenerAdapter) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueues(persistenceQueue(), webAppQueue());
    container.setMessageListener(webAppListenerAdapter);
    return container;
}

@Bean
PersistenceListener persistenceListener() {
    return new PersistenceListener();
}

@Bean
WebAppListener webAppListener() {
    return new WebAppListener();
}

奇怪的情况是，如果我首先使用persistenceListenerContainer（）方法，这就是正确工作的侦听器，然而，如果我更改代码并使用webAppListenerContainer（）方法，PersistenceListener将不工作，WebAppListener开始工作

有人能帮我解决这个问题吗