【问题标题】:Rabbit listener method is not getting invoked with the incoming messageRabbit 侦听器方法没有被传入消息调用
【发布时间】: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


【解决方案1】:

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

【讨论】:

    猜你喜欢
    • 2019-02-25
    • 2020-01-17
    • 2018-01-15
    • 1970-01-01
    • 1970-01-01
    • 2014-07-09
    • 1970-01-01
    • 2021-03-16
    • 1970-01-01
    相关资源
    最近更新 更多