From 3c535731f7f2d15549978e41e8232150db52dd48 Mon Sep 17 00:00:00 2001 From: ouyangxq <775153912@qq.com> Date: Sat, 5 Sep 2026 22:59:08 +0800 Subject: [PATCH] fix: configure finance wallet event delivery --- .../src/main/resources/application.yml | 1 + .../service/HttpFinanceEventClientTest.java | 19 +++++++++++++++++++ 2 files changed, 20 insertions(+) create mode 100644 event-bridge-service/src/test/java/com/baiyue/eventbridge/service/HttpFinanceEventClientTest.java diff --git a/event-bridge-service/src/main/resources/application.yml b/event-bridge-service/src/main/resources/application.yml index d8872f01f..c71fb2f2b 100644 --- a/event-bridge-service/src/main/resources/application.yml +++ b/event-bridge-service/src/main/resources/application.yml @@ -34,6 +34,7 @@ baiyue: consumer-url: ${EVENT_CONSUMER_URL:${LASTLEG_CONSUMER_URL:http://127.0.0.1:9303/internal/lastleg/events}} firstleg-consumer-url: ${FIRSTLEG_CONTAINER_EVENT_CONSUMER_URL:http://127.0.0.1:9202/internal/firstleg/v1/container-events} finance-consumer-url: ${FINANCE_FEE_EVENT_CONSUMER_URL:http://127.0.0.1:9203/internal/finance/v1/business-fee-source-events} + finance-wallet-consumer-url: ${FINANCE_WALLET_EVENT_CONSUMER_URL:http://127.0.0.1:9203/internal/finance/v1/wallet-command-events} security-consumer-url: ${LASTLEG_SECURITY_EVENT_CONSUMER_URL:http://127.0.0.1:9303/internal/lastleg/security/v1/events} fixed-delay: ${EVENT_DISPATCH_FIXED_DELAY:3000} batch-size: ${EVENT_DISPATCH_BATCH_SIZE:50} diff --git a/event-bridge-service/src/test/java/com/baiyue/eventbridge/service/HttpFinanceEventClientTest.java b/event-bridge-service/src/test/java/com/baiyue/eventbridge/service/HttpFinanceEventClientTest.java new file mode 100644 index 000000000..cac61af80 --- /dev/null +++ b/event-bridge-service/src/test/java/com/baiyue/eventbridge/service/HttpFinanceEventClientTest.java @@ -0,0 +1,19 @@ +package com.baiyue.eventbridge.service; + +import org.junit.jupiter.api.Test; + +import java.nio.file.Files; +import java.nio.file.Path; + +import static org.assertj.core.api.Assertions.assertThat; + +class HttpFinanceEventClientTest { + @Test + void walletConsumerUrlCanBeConfiguredForContainerDeployment() throws Exception { + String application = Files.readString(Path.of("src/main/resources/application.yml")); + + assertThat(application).contains( + "finance-wallet-consumer-url: ${FINANCE_WALLET_EVENT_CONSUMER_URL:" + + "http://127.0.0.1:9203/internal/finance/v1/wallet-command-events}"); + } +}