From d021a5d02b33a128d31f2467d135c8c79501b8ed Mon Sep 17 00:00:00 2001
From: Felix Reichenbach <felix.reichenbach@mgm-tp.com>
Date: Mon, 17 Mar 2025 11:11:16 +0100
Subject: [PATCH] OZG-7573 set public methods synchronized in
EingangStubReceiverStreamObserver
---
.../eingang/forwarder/EingangStubReceiverStreamObserver.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/forwarder/src/main/java/de/ozgcloud/eingang/forwarder/EingangStubReceiverStreamObserver.java b/forwarder/src/main/java/de/ozgcloud/eingang/forwarder/EingangStubReceiverStreamObserver.java
index 202ab2ec4..4031741b0 100644
--- a/forwarder/src/main/java/de/ozgcloud/eingang/forwarder/EingangStubReceiverStreamObserver.java
+++ b/forwarder/src/main/java/de/ozgcloud/eingang/forwarder/EingangStubReceiverStreamObserver.java
@@ -172,7 +172,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou
}
@Override
- public void onError(Throwable t) {
+ public synchronized void onError(Throwable t) {
LOG.error("Error happened. Receiving stream closed.", t);
closeOutputPipe();
closeInputPipe();
@@ -187,7 +187,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou
}
@Override
- public void onCompleted() {
+ public synchronized void onCompleted() {
formDataConsumer.accept(assembleFormData());
responseConsumer.accept(GrpcRouteForwardingResponse.getDefaultInstance());
}
--
GitLab