Skip to content
Snippets Groups Projects

Ozg 7573 forwarding interface

Merged Felix Reichenbach requested to merge OZG-7573-forwarding-interface into main
3 unresolved threads
3 files
+ 140
11
Compare changes
  • Side-by-side
  • Inline
Files
3
@@ -46,7 +46,7 @@ class ForwardingRemoteService {
private final VorgangService vorgangService;
private final ForwardingRequestMapper forwardingRequestMapper;
@GrpcClient("forwarder")
private final RouteForwardingServiceGrpc.RouteForwardingServiceStub routeForwardingServiceGrpc;
private final RouteForwardingServiceGrpc.RouteForwardingServiceStub serviceStub;
public void forward(ForwardingRequest request) {
CompletableFuture<Void> responseFuture = new CompletableFuture<>();
@@ -55,13 +55,14 @@ class ForwardingRemoteService {
}
void routeForwarding(ForwardingRequest request, ForwardingResponseObserver responseObserver) {
var requestStreamObserver = routeForwardingServiceGrpc.withInterceptors(new VorgangManagerClientCallContextAttachingInterceptor())
var requestStreamObserver = serviceStub.withInterceptors(new VorgangManagerClientCallContextAttachingInterceptor())
.routeForwarding(responseObserver);
try {
sendEingang(request, requestStreamObserver);
requestStreamObserver.onCompleted();
} catch (Throwable t) {
requestStreamObserver.onError(t);
throw t;
}
}
Loading