Ozg 7811 vorgaenge zur landesebene schicken
4 unresolved threads
4 unresolved threads
Merge request reports
Activity
requested review from @sebo
31 import de.ozgcloud.aggregation.Aggregation; 32 import de.ozgcloud.aggregation.AggregationManagerProperties; 33 import de.ozgcloud.aggregation.data.AggregationDataServiceGrpc; 34 import de.ozgcloud.aggregation.data.GrpcAggregationData; 35 import de.ozgcloud.aggregation.data.GrpcSendAggregationDataRequest; 36 import de.ozgcloud.aggregation.data.GrpcSendAggregationDataResponse; 37 import de.ozgcloud.aggregation.warehouse.DocumentEntry; 38 import io.grpc.stub.ClientCallStreamObserver; 39 import io.grpc.stub.ClientResponseObserver; 40 import lombok.Builder; 41 import lombok.Getter; 42 import lombok.RequiredArgsConstructor; 43 import net.devh.boot.grpc.client.inject.GrpcClient; 44 45 @RequiredArgsConstructor 46 public class AggregationDataRemoteService { 34 import de.ozgcloud.aggregation.data.GrpcAggregationData; 35 import de.ozgcloud.aggregation.data.GrpcSendAggregationDataRequest; 36 import de.ozgcloud.aggregation.data.GrpcSendAggregationDataResponse; 37 import de.ozgcloud.aggregation.warehouse.DocumentEntry; 38 import io.grpc.stub.ClientCallStreamObserver; 39 import io.grpc.stub.ClientResponseObserver; 40 import lombok.Builder; 41 import lombok.Getter; 42 import lombok.RequiredArgsConstructor; 43 import net.devh.boot.grpc.client.inject.GrpcClient; 44 45 @RequiredArgsConstructor 46 public class AggregationDataRemoteService { 47 48 @GrpcClient("aggregation-manager") 49 private final AggregationDataServiceGrpc.AggregationDataServiceStub serviceStub; 27 28 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; 29 import org.springframework.stereotype.Component; 30 31 import de.ozgcloud.aggregation.Aggregation; 32 import de.ozgcloud.aggregation.AggregationDataLoader; 33 import de.ozgcloud.aggregation.transformation.AggregationMapping; 34 import de.ozgcloud.common.errorhandling.TechnicalException; 35 import lombok.RequiredArgsConstructor; 36 import lombok.extern.log4j.Log4j2; 37 38 @Component 39 @ConditionalOnProperty("grpc.client.aggregation-manager.address") 40 @RequiredArgsConstructor 41 @Log4j2 42 public class AggregationRemoteDataLoader implements AggregationDataLoader { changed this line in version 2 of the diff
23 */ 24 package de.ozgcloud.aggregation.warehouse; 25 26 import org.apache.commons.lang3.StringUtils; 27 import org.springframework.stereotype.Component; 28 29 import de.ozgcloud.aggregation.Aggregation; 30 import de.ozgcloud.aggregation.AggregationDataLoader; 31 import de.ozgcloud.aggregation.transformation.AggregationMapping; 32 import lombok.RequiredArgsConstructor; 33 import lombok.extern.log4j.Log4j2; 34 35 @Component 36 @RequiredArgsConstructor 37 @Log4j2 38 public class AggregationWarehouseDataLoader implements AggregationDataLoader { changed this line in version 2 of the diff
mentioned in commit df40778e
Please register or sign in to reply