Использование RabbitMQ с Axon Framework веснойJAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Использование RabbitMQ с Axon Framework весной

Сообщение Anonymous »

Привет, я пытаюсь использовать 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
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»