Rabbit 侦听器方法没有被传入消息调用

Posted 2023-03-10

【中文标题】Rabbit 侦听器方法没有被传入消息调用

【英文标题】：Rabbit listener method is not getting invoked with the incoming message

【发布时间】：2022-01-19 16:45:57

【问题描述】：

我有一种方法可以在类似的行中使用消息，如下所示：

@RabbitListener(queues = "$com.rabbimq.myQueue")
public void receive(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag)
        throws IOException 
    log.info("Received msg: ",msg);
    channel.basicAck(tag, false);   

当我将它作为 SpringBoot 项目执行时，它可以正常工作。但是当我构建这个项目并将其作为依赖项放在我的另一个项目中时，它不再使用该消息。我希望这是一个可以被我的其他项目利用的通用项目。我在这个“消息消费”项目中放了一些记录器，我可以看到所有的 bean 都被创建了。但它没有调用这个特定的方法。非常感谢这里的任何指针。

【问题讨论】：

此方法所在的类必须声明为@Bean，或者，如果它是@Component，则必须在为组件扫描而扫描的包中。如果这些都不是问题，请提供MCRE，以便我们查看问题所在。

感谢 Gary 的 cmets。是的，你是对的。这是一个愚蠢的错误。我错过了将课程声明为@Bean。

【参考方案1】：

此方法所在的类必须声明为@Bean，或者，如果它是@Component，则它必须位于已扫描组件扫描的包中。