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 547475dc3125ce6fbd2450041de3d2bbb2984b01..c10dbbbcfe39cdbc86257f44ca6f146f4287cd03 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;