Skip to content

Commit c464c09

Browse files
dartartemdartartem
committed
Partially adapted to separate cdc
1 parent 2060012 commit c464c09

File tree

52 files changed

+217
-156
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

52 files changed

+217
-156
lines changed

‎buildSrc/src/main/groovy/FtgoServicePlugin.groovy

+4-1
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,12 @@ class FtgoServicePlugin implements Plugin<Project> {
1717
}
1818
}
1919

20+
project.configurations.all {
21+
exclude group: 'org.apache.logging.log4j'
22+
exclude group: 'log4j'
23+
}
2024

2125
project.dependencies {
22-
2326
compile 'org.springframework.cloud:spring-cloud-starter-sleuth'
2427
compile 'org.springframework.cloud:spring-cloud-starter-zipkin'
2528
compile 'io.zipkin.brave:brave-bom:4.17.1'

‎docker-compose-mysql-schema-per-service.yml

+4-4
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
version: '3'
22
services:
33
zookeeper:
4-
image: eventuateio/eventuateio-local-zookeeper:0.30.2.RELEASE
4+
image: test-eventuate-zookeeper
55
ports:
66
- 2181:2181
77
- 2888:2888
88
- 3888:3888
99
kafka:
10-
image: eventuateio/eventuateio-local-kafka:0.30.2.RELEASE
10+
image: test-eventuate-kafka
1111
ports:
1212
- 9092:9092
1313
depends_on:
@@ -24,8 +24,8 @@ services:
2424
- MYSQL_ROOT_PASSWORD=rootpassword
2525
- MYSQL_USER=mysqluser
2626
- MYSQL_PASSWORD=mysqlpw
27-
tram-cdc-service:
28-
image: eventuateio/eventuate-tram-cdc-mysql-service:0.21.2.RELEASE
27+
cdc-service:
28+
image: test-eventuate-cdc-service
2929
ports:
3030
- "8099:8080"
3131
depends_on:

‎docker-compose.yml

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
version: '3'
22
services:
33
zookeeper:
4-
image: eventuateio/eventuateio-local-zookeeper:0.30.2.RELEASE
4+
image: test-eventuate-zookeeper
55
ports:
66
- 2181:2181
77
- 2888:2888
88
- 3888:3888
99
kafka:
10-
image: eventuateio/eventuateio-local-kafka:0.30.2.RELEASE
10+
image: test-eventuate-kafka
1111
ports:
1212
- 9092:9092
1313
depends_on:
@@ -25,7 +25,7 @@ services:
2525
- MYSQL_USER=mysqluser
2626
- MYSQL_PASSWORD=mysqlpw
2727
tram-cdc-service:
28-
image: eventuateio/eventuate-tram-cdc-mysql-service:0.21.2.RELEASE
28+
image: test-eventuate-cdc-service
2929
ports:
3030
- "8099:8080"
3131
depends_on:

‎ftgo-accounting-service/src/main/java/net/chrisrichardson/ftgo/accountingservice/main/AccountingServiceMain.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,9 @@
22

33
import io.eventuate.javaclient.driver.EventuateDriverConfiguration;
44
import io.eventuate.jdbckafka.TramJdbcKafkaConfiguration;
5-
import io.eventuate.tram.commands.common.ChannelMapping;
6-
import io.eventuate.tram.commands.common.DefaultChannelMapping;
75
import io.eventuate.tram.commands.producer.TramCommandProducerConfiguration;
6+
import io.eventuate.tram.messaging.common.ChannelMapping;
7+
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
88
import net.chrisrichardson.ftgo.accountingservice.messaging.AccountingMessagingConfiguration;
99
import net.chrisrichardson.ftgo.accountingservice.web.AccountingWebConfiguration;
1010
import org.springframework.boot.SpringApplication;

‎ftgo-accounting-service/src/main/java/net/chrisrichardson/ftgo/accountingservice/messaging/AccountingMessagingConfiguration.java

+10-3
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,10 @@
33
import io.eventuate.javaclient.spring.EnableEventHandlers;
44
import io.eventuate.tram.commands.consumer.CommandDispatcher;
55
import io.eventuate.tram.consumer.common.DuplicateMessageDetector;
6+
import io.eventuate.tram.events.common.DefaultDomainEventNameMapping;
67
import io.eventuate.tram.events.subscriber.DomainEventDispatcher;
78
import io.eventuate.tram.messaging.consumer.MessageConsumer;
9+
import io.eventuate.tram.messaging.producer.MessageProducer;
810
import io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEventSubscriber;
911
import net.chrisrichardson.ftgo.accountingservice.domain.Account;
1012
import net.chrisrichardson.ftgo.accountingservice.domain.AccountServiceConfiguration;
@@ -27,7 +29,10 @@ public AccountingEventConsumer accountingEventConsumer() {
2729

2830
@Bean
2931
public DomainEventDispatcher domainEventDispatcher(AccountingEventConsumer accountingEventConsumer, MessageConsumer messageConsumer) {
30-
return new DomainEventDispatcher("accountingServiceDomainEventDispatcher", accountingEventConsumer.domainEventHandlers(), messageConsumer);
32+
return new DomainEventDispatcher("accountingServiceDomainEventDispatcher",
33+
accountingEventConsumer.domainEventHandlers(),
34+
messageConsumer,
35+
new DefaultDomainEventNameMapping());
3136
}
3237

3338
@Bean
@@ -38,8 +43,10 @@ public AccountingServiceCommandHandler accountCommandHandler() {
3843

3944
@Bean
4045
public CommandDispatcher commandDispatcher(AccountingServiceCommandHandler target,
41-
AccountServiceChannelConfiguration data) {
42-
return new CommandDispatcher(data.getCommandDispatcherId(), target.commandHandlers());
46+
AccountServiceChannelConfiguration data,
47+
MessageConsumer messageConsumer,
48+
MessageProducer messageProducer) {
49+
return new CommandDispatcher(data.getCommandDispatcherId(), target.commandHandlers(), messageConsumer, messageProducer);
4350
}
4451

4552
@Bean

‎ftgo-accounting-service/src/main/resources/application.properties

+4
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11
spring.application.name=ftgo-accounting-service
22

3+
management.health.jms.enabled=false
4+
management.health.redis.enabled=false
5+
management.endpoint.health.show-details=always
6+
37
spring.jpa.generate-ddl=true
48
logging.level.org.springframework.orm.jpa=INFO
59
logging.level.org.hibernate.SQL=DEBUG

‎ftgo-accounting-service/src/test/java/net/chrisrichardson/ftgo/accountingservice/messaging/AccountingServiceCommandHandlerTest.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -2,19 +2,18 @@
22

33
import io.eventuate.sync.AggregateRepository;
44
import io.eventuate.javaclient.spring.jdbc.EmbeddedTestAggregateStoreConfiguration;
5-
import io.eventuate.tram.commands.common.ChannelMapping;
6-
import io.eventuate.tram.commands.common.DefaultChannelMapping;
75
import io.eventuate.tram.commands.producer.CommandProducer;
86
import io.eventuate.tram.commands.producer.TramCommandProducerConfiguration;
97
import io.eventuate.tram.events.publisher.DomainEventPublisher;
108
import io.eventuate.tram.events.publisher.TramEventsPublisherConfiguration;
119
import io.eventuate.tram.inmemory.TramInMemoryConfiguration;
10+
import io.eventuate.tram.messaging.common.ChannelMapping;
11+
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
1212
import io.eventuate.tram.sagas.common.SagaCommandHeaders;
1313
import io.eventuate.tram.testutil.TestMessageConsumer;
1414
import io.eventuate.tram.testutil.TestMessageConsumerFactory;
1515
import net.chrisrichardson.ftgo.accountingservice.domain.Account;
1616
import net.chrisrichardson.ftgo.accountingservice.domain.AccountCommand;
17-
import net.chrisrichardson.ftgo.accountingservice.domain.AuthorizeCommandInternal;
1817
import net.chrisrichardson.ftgo.accountservice.api.AccountingServiceChannels;
1918
import net.chrisrichardson.ftgo.accountservice.api.AuthorizeCommand;
2019
import net.chrisrichardson.ftgo.common.Money;

‎ftgo-common/build.gradle

+1
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ dependencies {
55
compile "org.springframework.boot:spring-boot-starter-data-jpa:$springBootVersion"
66

77
compile "io.eventuate.client.java:eventuate-client-java-common-impl:$eventuateClientVersion"
8+
compile "io.eventuate.common:eventuate-common-json-mapper:$eventuateCommonVersion"
89

910
testCompile "org.springframework.boot:spring-boot-starter-test:$springBootVersion"
1011

‎ftgo-common/src/main/java/net/chrisrichardson/ftgo/common/CommonJsonMapperInitializer.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package net.chrisrichardson.ftgo.common;
22

3-
import io.eventuate.javaclient.commonimpl.JSonMapper;
3+
import io.eventuate.common.json.mapper.JSonMapper;
44

55
import javax.annotation.PostConstruct;
66

‎ftgo-common/src/test/java/net/chrisrichardson/ftgo/common/MoneySerializationTest.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,7 @@
11
package net.chrisrichardson.ftgo.common;
22

33
import com.fasterxml.jackson.databind.JsonMappingException;
4-
import com.fasterxml.jackson.databind.ObjectMapper;
5-
import io.eventuate.javaclient.commonimpl.JSonMapper;
4+
import io.eventuate.common.json.mapper.JSonMapper;
65
import org.apache.commons.lang.builder.EqualsBuilder;
76
import org.apache.commons.lang.builder.HashCodeBuilder;
87
import org.apache.commons.lang.builder.ToStringBuilder;

‎ftgo-consumer-service/src/main/java/net/chrisrichardson/ftgo/consumerservice/domain/Consumer.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package net.chrisrichardson.ftgo.consumerservice.domain;
22

3-
import io.eventuate.tram.events.ResultWithEvents;
3+
import io.eventuate.tram.events.publisher.ResultWithEvents;
44
import net.chrisrichardson.ftgo.common.Money;
55
import net.chrisrichardson.ftgo.common.PersonName;
66

‎ftgo-consumer-service/src/main/java/net/chrisrichardson/ftgo/consumerservice/domain/ConsumerService.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package net.chrisrichardson.ftgo.consumerservice.domain;
22

3-
import io.eventuate.tram.events.ResultWithEvents;
43
import io.eventuate.tram.events.publisher.DomainEventPublisher;
4+
import io.eventuate.tram.events.publisher.ResultWithEvents;
55
import net.chrisrichardson.ftgo.common.Money;
66
import net.chrisrichardson.ftgo.common.PersonName;
77
import org.springframework.beans.factory.annotation.Autowired;

‎ftgo-consumer-service/src/main/java/net/chrisrichardson/ftgo/consumerservice/domain/ConsumerServiceConfiguration.java

+14-4
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,12 @@
11
package net.chrisrichardson.ftgo.consumerservice.domain;
22

3-
import io.eventuate.tram.commands.common.ChannelMapping;
4-
import io.eventuate.tram.commands.common.DefaultChannelMapping;
53
import io.eventuate.tram.commands.consumer.CommandDispatcher;
64
import io.eventuate.tram.events.publisher.TramEventsPublisherConfiguration;
5+
import io.eventuate.tram.messaging.common.ChannelMapping;
6+
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
7+
import io.eventuate.tram.messaging.consumer.MessageConsumer;
8+
import io.eventuate.tram.messaging.producer.MessageProducer;
9+
import io.eventuate.tram.sagas.common.SagaLockManager;
710
import io.eventuate.tram.sagas.participant.SagaCommandDispatcher;
811
import io.eventuate.tram.sagas.participant.SagaParticipantConfiguration;
912
import net.chrisrichardson.ftgo.common.CommonConfiguration;
@@ -34,8 +37,15 @@ public ConsumerService consumerService() {
3437
}
3538

3639
@Bean
37-
public CommandDispatcher commandDispatcher(ConsumerServiceCommandHandlers consumerServiceCommandHandlers) {
38-
return new SagaCommandDispatcher("consumerServiceDispatcher", consumerServiceCommandHandlers.commandHandlers());
40+
public CommandDispatcher commandDispatcher(ConsumerServiceCommandHandlers consumerServiceCommandHandlers,
41+
MessageConsumer messageConsumer,
42+
MessageProducer messageProducer,
43+
SagaLockManager sagaLockManager) {
44+
return new SagaCommandDispatcher("consumerServiceDispatcher",
45+
consumerServiceCommandHandlers.commandHandlers(),
46+
messageConsumer,
47+
messageProducer,
48+
sagaLockManager);
3949
}
4050

4151
@Bean

‎ftgo-consumer-service/src/main/java/net/chrisrichardson/ftgo/consumerservice/web/ConsumerController.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package net.chrisrichardson.ftgo.consumerservice.web;
22

3-
import io.eventuate.tram.events.ResultWithEvents;
3+
import io.eventuate.tram.events.publisher.ResultWithEvents;
44
import net.chrisrichardson.ftgo.consumerservice.api.web.CreateConsumerRequest;
55
import net.chrisrichardson.ftgo.consumerservice.api.web.CreateConsumerResponse;
66
import net.chrisrichardson.ftgo.consumerservice.domain.Consumer;

‎ftgo-consumer-service/src/main/resources/application.properties

+4
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11
spring.application.name=ftgo-consumer-service
22

3+
management.health.jms.enabled=false
4+
management.health.redis.enabled=false
5+
management.endpoint.health.show-details=always
6+
37
spring.jpa.generate-ddl=true
48
logging.level.org.springframework.orm.jpa=INFO
59
logging.level.org.hibernate.SQL=DEBUG

‎ftgo-end-to-end-tests/src/test/java/net/chrisrichardson/ftgo/endtoendtests/EndToEndTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.jayway.restassured.RestAssured;
44
import com.jayway.restassured.config.ObjectMapperConfig;
55
import com.jayway.restassured.config.RestAssuredConfig;
6-
import io.eventuate.javaclient.commonimpl.JSonMapper;
6+
import io.eventuate.common.json.mapper.JSonMapper;
77
import net.chrisrichardson.ftgo.common.CommonJsonMapperInitializer;
88
import net.chrisrichardson.ftgo.common.Money;
99
import net.chrisrichardson.ftgo.common.PersonName;

‎ftgo-kitchen-service/src/main/java/net/chrisrichardson/ftgo/kitchenservice/main/KitchenServiceMain.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package net.chrisrichardson.ftgo.kitchenservice.main;
22

33
import io.eventuate.jdbckafka.TramJdbcKafkaConfiguration;
4-
import io.eventuate.tram.commands.common.ChannelMapping;
5-
import io.eventuate.tram.commands.common.DefaultChannelMapping;
4+
import io.eventuate.tram.messaging.common.ChannelMapping;
5+
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
66
import net.chrisrichardson.eventstore.examples.customersandorders.commonswagger.CommonSwaggerConfiguration;
77
import net.chrisrichardson.ftgo.kitchenservice.messagehandlers.KitchenServiceMessageHandlersConfiguration;
88
import net.chrisrichardson.ftgo.kitchenservice.web.KitchenServiceWebConfiguration;

‎ftgo-kitchen-service/src/main/java/net/chrisrichardson/ftgo/kitchenservice/messagehandlers/KitchenServiceMessageHandlersConfiguration.java

+16-3
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,10 @@
11
package net.chrisrichardson.ftgo.kitchenservice.messagehandlers;
22

3+
import io.eventuate.tram.events.common.DefaultDomainEventNameMapping;
34
import io.eventuate.tram.events.subscriber.DomainEventDispatcher;
45
import io.eventuate.tram.messaging.consumer.MessageConsumer;
6+
import io.eventuate.tram.messaging.producer.MessageProducer;
7+
import io.eventuate.tram.sagas.common.SagaLockManager;
58
import io.eventuate.tram.sagas.participant.SagaCommandDispatcher;
69
import io.eventuate.tram.sagas.participant.SagaParticipantConfiguration;
710
import net.chrisrichardson.ftgo.common.CommonConfiguration;
@@ -25,12 +28,22 @@ public KitchenServiceCommandHandler kitchenServiceCommandHandler() {
2528
}
2629

2730
@Bean
28-
public SagaCommandDispatcher kitchenServiceSagaCommandDispatcher(KitchenServiceCommandHandler kitchenServiceCommandHandler) {
29-
return new SagaCommandDispatcher("kitchenServiceCommands", kitchenServiceCommandHandler.commandHandlers());
31+
public SagaCommandDispatcher kitchenServiceSagaCommandDispatcher(KitchenServiceCommandHandler kitchenServiceCommandHandler,
32+
MessageConsumer messageConsumer,
33+
MessageProducer messageProducer,
34+
SagaLockManager sagaLockManager) {
35+
return new SagaCommandDispatcher("kitchenServiceCommands",
36+
kitchenServiceCommandHandler.commandHandlers(),
37+
messageConsumer,
38+
messageProducer,
39+
sagaLockManager);
3040
}
3141

3242
@Bean
3343
public DomainEventDispatcher domainEventDispatcher(KitchenServiceEventConsumer kitchenServiceEventConsumer, MessageConsumer messageConsumer) {
34-
return new DomainEventDispatcher("kitchenServiceEvents", kitchenServiceEventConsumer.domainEventHandlers(), messageConsumer); // @Autowire
44+
return new DomainEventDispatcher("kitchenServiceEvents",
45+
kitchenServiceEventConsumer.domainEventHandlers(),
46+
messageConsumer,
47+
new DefaultDomainEventNameMapping()); // @Autowire
3548
}
3649
}

‎ftgo-kitchen-service/src/main/resources/application.properties

+4
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11
spring.application.name=ftgo-kitchen-service
22

3+
management.health.jms.enabled=false
4+
management.health.redis.enabled=false
5+
management.endpoint.health.show-details=always
6+
37
spring.jpa.generate-ddl=true
48
logging.level.org.springframework.orm.jpa=INFO
59
logging.level.org.hibernate.SQL=DEBUG

‎ftgo-kitchen-service/src/test/java/net/chrisrichardson/ftgo/kitchenservice/domain/KitchenServiceInMemoryIntegrationTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
package net.chrisrichardson.ftgo.kitchenservice.domain;
22

33

4-
import io.eventuate.tram.commands.common.ChannelMapping;
5-
import io.eventuate.tram.commands.common.DefaultChannelMapping;
64
import io.eventuate.tram.commands.producer.CommandProducer;
75
import io.eventuate.tram.commands.producer.TramCommandProducerConfiguration;
86
import io.eventuate.tram.inmemory.TramInMemoryConfiguration;
7+
import io.eventuate.tram.messaging.common.ChannelMapping;
8+
import io.eventuate.tram.messaging.common.DefaultChannelMapping;
99
import io.eventuate.tram.sagas.common.SagaCommandHeaders;
1010
import io.eventuate.tram.testutil.TestMessageConsumer;
1111
import io.eventuate.tram.testutil.TestMessageConsumerFactory;

‎ftgo-order-history-service/build.gradle

+2-2
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ dependencyManagement {
2020
}
2121
}
2222

23-
2423
dependencies {
2524
compile 'com.amazonaws:aws-java-sdk-dynamodb:1.11.158'
2625

@@ -30,9 +29,10 @@ dependencies {
3029
exclude module: "spring-boot-starter-data-jpa"
3130
}
3231

33-
compile "io.eventuate.tram.core:eventuate-tram-consumer-kafka:$eventuateTramVersion"
32+
compile "io.eventuate.messaging.kafka:eventuate-messaging-kafka-consumer:$eventuateMessagingKafkaVersion"
3433

3534
compile "io.eventuate.tram.core:eventuate-tram-events:$eventuateTramVersion"
35+
compile "io.eventuate.tram.core:eventuate-tram-consumer-wrappers:$eventuateTramVersion"
3636

3737
compile "org.springframework.boot:spring-boot-starter-actuator:$springBootVersion"
3838
compile "org.springframework.boot:spring-boot-starter-web:$springBootVersion"

‎ftgo-order-history-service/src/main/java/net/chrisrichardson/ftgo/cqrs/orderhistory/main/OrderHistoryServiceMain.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
package net.chrisrichardson.ftgo.cqrs.orderhistory.main;
22

3-
import io.eventuate.tram.consumer.kafka.TramConsumerKafkaConfiguration;
3+
import io.eventuate.messaging.kafka.consumer.MessageConsumerKafkaConfiguration;
4+
import io.eventuate.tram.consumer.common.TramConsumerCommonConfiguration;
45
import net.chrisrichardson.eventstore.examples.customersandorders.commonswagger.CommonSwaggerConfiguration;
56
import net.chrisrichardson.ftgo.cqrs.orderhistory.messaging.OrderHistoryServiceMessagingConfiguration;
67
import net.chrisrichardson.ftgo.cqrs.orderhistory.web.OrderHistoryWebConfiguration;
78
import org.springframework.boot.SpringApplication;
89
import org.springframework.boot.autoconfigure.SpringBootApplication;
9-
import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
1010
import org.springframework.context.annotation.Import;
1111

1212
@SpringBootApplication
1313
@Import({OrderHistoryWebConfiguration.class, OrderHistoryServiceMessagingConfiguration.class,
14-
TramConsumerKafkaConfiguration.class, CommonSwaggerConfiguration.class})
14+
MessageConsumerKafkaConfiguration.class, TramConsumerCommonConfiguration.class, CommonSwaggerConfiguration.class})
1515
public class OrderHistoryServiceMain {
1616

1717
public static void main(String[] args) {

‎ftgo-order-history-service/src/main/java/net/chrisrichardson/ftgo/cqrs/orderhistory/messaging/OrderHistoryServiceMessagingConfiguration.java

+13-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,10 @@
11
package net.chrisrichardson.ftgo.cqrs.orderhistory.messaging;
22

3+
import io.eventuate.messaging.kafka.consumer.MessageConsumerKafkaImpl;
4+
import io.eventuate.tram.consumer.common.MessageConsumerImplementation;
35
import io.eventuate.tram.consumer.common.TramNoopDuplicateMessageDetectorConfiguration;
6+
import io.eventuate.tram.consumer.wrappers.EventuateKafkaMessageConsumerWrapper;
7+
import io.eventuate.tram.events.common.DefaultDomainEventNameMapping;
48
import io.eventuate.tram.events.subscriber.DomainEventDispatcher;
59
import io.eventuate.tram.messaging.consumer.MessageConsumer;
610
import net.chrisrichardson.ftgo.common.CommonConfiguration;
@@ -13,14 +17,22 @@
1317
@Import({CommonConfiguration.class, TramNoopDuplicateMessageDetectorConfiguration.class})
1418
public class OrderHistoryServiceMessagingConfiguration {
1519

20+
@Bean
21+
public MessageConsumerImplementation messageConsumerImplementation(MessageConsumerKafkaImpl messageConsumerKafka) {
22+
return new EventuateKafkaMessageConsumerWrapper(messageConsumerKafka);
23+
}
24+
1625
@Bean
1726
public OrderHistoryEventHandlers orderHistoryEventHandlers(OrderHistoryDao orderHistoryDao) {
1827
return new OrderHistoryEventHandlers(orderHistoryDao);
1928
}
2029

2130
@Bean
2231
public DomainEventDispatcher orderHistoryDomainEventDispatcher(OrderHistoryEventHandlers orderHistoryEventHandlers, MessageConsumer messageConsumer) {
23-
return new DomainEventDispatcher("orderHistoryDomainEventDispatcher", orderHistoryEventHandlers.domainEventHandlers(), messageConsumer);
32+
return new DomainEventDispatcher("orderHistoryDomainEventDispatcher",
33+
orderHistoryEventHandlers.domainEventHandlers(),
34+
messageConsumer,
35+
new DefaultDomainEventNameMapping());
2436
}
2537

2638
}

0 commit comments

Comments
 (0)