Axon Framework AMQP - 不获取消息

Question

我参考 https://www.youtube.com/watch?v=Jp-rW-XOYzA&list=PLgGXSWYM2FpOa_FTla-x5Wd10dpmgrRC4&index=54

开发了 Spring Boot + Axon (Bootiful CQRS with Axon) 代码

我已将所有代码放在这里：https://github.com/JavaHelper/axon-tutorials/tree/master/axon-complaints-demo。我面临的问题是非常奇怪的问题。

场景 1：

如果我启动两个应用程序 (one on 8080 and other on 8081) 并点击以下端点，那么 RabbitMQ 队列中不会出现任何内容，因此，当我点击 http://localhost:8081/ 时也不会出现任何内容。它是空白的。

CURL 命令

curl -H "Content-Type:application/json" -d '{"company" : "apple", "description" : "My Kep"}' http://localhost:8080

curl -H "Content-Type:application/json" -d '{"company" : "apple", "description" : "Laptop not working"}' http://localhost:8080

curl -H "Content-Type:application/json" -d '{"company" : "Mastercrd", "description" : "Debit and Clearning does not works"}' http://localhost:8080

场景 2：

如果我先启动 demo-complaints 然后点击上面的 curl 命令，那么 RabbitMQ 会显示队列计数 3。之后我成功启动 demo-complaints-stats，然后点击 http://localhost:8081/

谁能指导一下哪里出了问题？

已提供源代码link。

Answer 1

您链接到的演示已经相对较旧。或者换句话说，事情可能已经发生了变化，从一开始就不清楚。您是否已 here 查看手册并遵循必要的步骤？

我的直觉是您尚未将 AMQP 消息源配置为事件处理程序的事件源。为此，您需要为事件处理程序指定一个处理组，并将 AMQP 消息源绑定到该处理组。

Axon Framework AMQP - 不获取消息

Axon Framework AMQP - Doesn't fetches the messages

java

spring-boot

rabbitmq

axon