Привет, я пытаюсь использовать 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
Программисты JAVA общаются здесь
-
Anonymous
1728747060
Anonymous
Привет, я пытаюсь использовать RabbitMQ в качестве шины событий в своем приложении Spring Axon, но во время настройки я столкнулся с проблемой в моем application.yml, из-за которой я не могу установить обмен axon amqp, хотя я его добавил в мой pom.xml
Cannot resolve configuration property 'axon. amqp. exchange'
Любая помощь будет оценена по достоинству.
[b]Application.yml[/b]
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
[b]Конфигурация AxonAMQP[/b]
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);
}
}
[b]pom.xml[/b]
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
Подробнее здесь: [url]https://stackoverflow.com/questions/79081319/using-rabbitmq-with-axon-framework-in-spring[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия