Axon Framework AMQP - не получает сообщения - PullRequest
Новая
       8

Axon Framework AMQP - не получает сообщения

0 голосов
/ 04 ноября 2018

Я разработал Spring Boot + Axon (Bootiful CQRS with Axon) код, взяв ссылку из https://www.youtube.com/watch?v=Jp-rW-XOYzA&list=PLgGXSWYM2FpOa_FTla-x5Wd10dpmgrRC4&index=54

Я разместил здесь все по коду: 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/

ничего не появляется

Может кто-нибудь подсказать, что не так?

Ссылка на исходный код уже предоставлена.

1 Ответ

0 голосов
/ 05 ноября 2018

Демо, на которое вы ссылаетесь, уже относительно старое. Или иначе, вещи могли измениться, которые не ясны с этого начала. Вы ознакомились с руководством по здесь и выполнили необходимые шаги?

Моя догадка заключается в том, что вы не настроили свой источник сообщений AMQP в качестве источника событий для вашего обработчика событий. Для этого вам нужно указать группу обработки для вашего обработчика событий и привязать источник сообщений AMQP к этой группе обработки.

...