Spring Boot应用不消耗队列消息

Question

我有兔子MQ经纪人在服务之间进行异步传达。 服务正在将消息发送到队列。我检查了队列，服务A的消息到达：

我正在尝试在服务B 中创建一个听众，以消耗服务A。它似乎已成功联系在一起。

问题是服务B成功开始，但它正在接收兔子MQ的消息。

以下是侦听器的实现：

@Slf4j
@Component
public class EventListener {

    public static final String QUEUE_NAME = "events";

    @RabbitListener(
            bindings = {
                    @QueueBinding(
                            value = @Queue(QUEUE_NAME),
                            exchange = @Exchange("exchange")
                    )

            }
    )
    public void handleTaskPayload(@Payload String payload) {
        System.out.println(payload);
    }
}

我验证了兔子MQ中的队列和交换信息，它们是正确的。

一切正常工作，并且在服务A或服务B中没有错误的错误，这使此问题更难调试。

我试图从RabbitMQ的队列GetMessage中检索消息，如下所示：

{"id":"1",:"name:"Test","created":null}

感谢您对解决此问题的任何帮助或指导。

此致， 兰多。

ps

i创建了一个新的测试队列，如以下内容，并发布了一些消息：

如下所示，仍然无法触发侦听器来收听侦听器队列事件：

@Slf4j
@Component
public class RobotRunEventListener {

    public static final String QUEUE_NAME = "test";

    @RabbitListener(
            bindings = {
                    @QueueBinding(
                            value = @Queue(QUEUE_NAME),
                            key = "test",
                            exchange = @Exchange("default")
                    )

            }
    )
    public void handleTaskPayload(@Payload String payload) {
        System.out.println(payload);
    }

Answer 1

尝试这种方法：

 @RabbitListener(queues = "test")
 public void receive(String in, @Headers Map<String, Object> headers) throws IOException  {
 }

Answer 2

问题是我正在使用的Spring Boot应用程序具有@conditional（config.class），该应用程序阻止了下面的BEAN创建：

@Slf4j
@Conditional(Config.class)
@EnableRabbit
public class InternalRabbitBootstrapConfiguration {
    @Bean
    public RabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMaxConcurrentConsumers(5);
        return factory;
    }
...

这导致Spring Boot应用程序未听兔子MQ事件。 config.class需要一个特定的配置文件，以使应用程序能够收听兔子MQ事件。

public class DexiModeCondition implements Condition {

    @Override
    public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {

        String[] activeProfiles = context.getEnvironment().getActiveProfiles();

        return activeProfiles[0].equalsIgnoreCase(mode);
    }
}