From 65efb02609c4ded027921fd9c9882cf8fddfd4ae Mon Sep 17 00:00:00 2001
From: Krzysztof <krzysztof.witukiewicz@mgm-tp.com>
Date: Thu, 24 Apr 2025 09:20:59 +0200
Subject: [PATCH] OZG-7811 OZG-8099 AggregationDataRemoteService conditional on
property
---
.../aggregation/extern/AggregationDataRemoteService.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/extern/AggregationDataRemoteService.java b/aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/extern/AggregationDataRemoteService.java
index 547475d..c10dbbb 100644
--- a/aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/extern/AggregationDataRemoteService.java
+++ b/aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/extern/AggregationDataRemoteService.java
@@ -28,6 +28,9 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;
import java.util.stream.Stream;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Service;
+
import de.ozgcloud.aggregation.AggregationManagerProperties;
import de.ozgcloud.aggregation.data.AggregationDataServiceGrpc;
import de.ozgcloud.aggregation.data.GrpcAggregationData;
@@ -39,12 +42,16 @@ import io.grpc.stub.ClientResponseObserver;
import lombok.Builder;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
+import net.devh.boot.grpc.client.inject.GrpcClient;
+@Service
+@ConditionalOnProperty("grpc.client.aggregation-manager.address")
@RequiredArgsConstructor
class AggregationDataRemoteService {
static final int BATCH_SIZE = 100;
+ @GrpcClient("aggregation-manager")
private final AggregationDataServiceGrpc.AggregationDataServiceStub serviceStub;
private final AggregationManagerProperties properties;
private final GrpcAggregationDataMapper grpcAggregationDataMapper;
--
GitLab