Skip to content
Snippets Groups Projects
Commit 65efb026 authored by Krzysztof Witukiewicz's avatar Krzysztof Witukiewicz
Browse files

OZG-7811 OZG-8099 AggregationDataRemoteService conditional on property

parent 5c7df168
No related branches found
No related tags found
1 merge request!23Ozg 7811 vorgaenge zur landesebene schicken
......@@ -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;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment