【发布时间】: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。
标签: java rabbitmq message-queue amqp spring-rabbit