Привет, я пытаюсь использовать RabbitMQ в качестве шины событий в своем приложении Spring Axon, но во время настройки я столкнулся с проблемой в моем application.yml, из-за которой я не могу установить обмен axon amqp, хотя я его добавил в мой pom.xml
Cannot resolve configuration property 'axon. amqp. exchange'
Любая помощь будет оценена по достоинству.
Application.yml
spring:
application:
name: ecommerce-cqrs-command
datasource:
url: jdbc:mysql://localhost:3306/event_store_db
username: root
password: password
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
axon:
amqp:
exchange: AxonExchange
eventhandling:
processors:
UserAggregate:
mode: subscribing
axonserver:
enabled: false
distributed:
enabled: false
server:
port: 8081
Конфигурация AxonAMQP
import org.axonframework.config.EventProcessingConfigurer;
import org.axonframework.extensions.amqp.eventhandling.DefaultAMQPMessageConverter;
import org.axonframework.extensions.amqp.eventhandling.spring.SpringAMQPMessageSource;
import org.axonframework.serialization.Serializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class AxonAMQPConfiguration {
@Bean
public SpringAMQPMessageSource rabbitMQMessageSource(Serializer serializer) {
return new SpringAMQPMessageSource(
DefaultAMQPMessageConverter.builder()
.serializer(serializer)
.build()
);
}
public void configure(EventProcessingConfigurer configurer, SpringAMQPMessageSource rabbitMQMessageSource) {
configurer.registerSubscribingEventProcessor("UserAggregate", c -> rabbitMQMessageSource);
}
}
pom.xml
4.0.0
com.jasper.ecommerce
ecommerce-cqrs-parent
1.0-SNAPSHOT
../pom.xml
cqrs-command-service
0.0.1-SNAPSHOT
CQRS Command Service
CQRS-based e-commerce application ( Command )
17
org.springframework.boot
spring-boot-starter-data-jpa
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-devtools
runtime
true
com.mysql
mysql-connector-j
runtime
org.projectlombok
lombok
true
org.springframework.boot
spring-boot-starter-test
test
org.axonframework
axon-spring-boot-starter
4.10.0
com.rabbitmq
amqp-client
5.22.0
org.springframework.boot
spring-boot-starter-amqp
org.axonframework.extensions.amqp
axon-amqp
4.10.0
com.jasper.ecommerce
ecommerce-cqrs-shared
0.0.1-SNAPSHOT
org.springframework.boot
spring-boot-maven-plugin
org.projectlombok
lombok
Подробнее здесь: https://stackoverflow.com/questions/790 ... -in-spring
Использование RabbitMQ с Axon Framework весной ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Сервер Axon постоянно выдает исключение InsufficientAuthenticationException, как это решить?
Anonymous » » в форуме JAVA - 0 Ответы
- 20 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Axon nohandlerforCommandException при использовании AxonFramework без пружинной загрузки
Anonymous » » в форуме JAVA - 0 Ответы
- 14 Просмотры
-
Последнее сообщение Anonymous
-