fix: configure finance wallet event delivery
This commit is contained in:
@@ -34,6 +34,7 @@ baiyue:
|
|||||||
consumer-url: ${EVENT_CONSUMER_URL:${LASTLEG_CONSUMER_URL:http://127.0.0.1:9303/internal/lastleg/events}}
|
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}
|
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-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}
|
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}
|
fixed-delay: ${EVENT_DISPATCH_FIXED_DELAY:3000}
|
||||||
batch-size: ${EVENT_DISPATCH_BATCH_SIZE:50}
|
batch-size: ${EVENT_DISPATCH_BATCH_SIZE:50}
|
||||||
|
|||||||
+19
@@ -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}");
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user