From 331710f2884764d297c253f577569305448f38de Mon Sep 17 00:00:00 2001
From: AKurakin <akurakin@mfd.ru>
Date: Thu, 9 Feb 2023 12:34:30 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-189=20?=
 =?UTF-8?q?=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D0=BB=20=D0=BB=D0=BE=D0=B3?=
 =?UTF-8?q?=D0=B8,=20=D1=87=D1=82=D0=BE=D0=B1=D1=8B=20=D0=B1=D1=8B=D0=BB?=
 =?UTF-8?q?=D0=BE=20=D1=8F=D1=81=D0=BD=D0=BE=20=D0=BF=D1=80=D0=BE=20=D0=B0?=
 =?UTF-8?q?=D1=81=D1=81=D0=B8=D0=BD=D1=85=D1=80=D0=BE=D0=BD=D0=BD=D0=BE?=
 =?UTF-8?q?=D1=81=D1=82=D1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/ru/spcex/clearing/service/Clearing.java       | 2 ++
 .../main/java/ru/spcex/clearing/service/ClearingService.java    | 1 +
 2 files changed, 3 insertions(+)

diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
index c7c78d5fa..7dcbd75a6 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
@@ -188,6 +188,8 @@ public class Clearing {
                     //обновлен, и была проблема была с сетью/недоступностью кафки etc.
                 } catch (InterruptedException e) {
                     log.error(ExceptionUtils.getStackTrace(e));
+                    Thread.currentThread().interrupt();
+                    throw new RuntimeException(e);
                 }
                 if (!Objects.equals(lastAccBalanceResponseId, sentRequestId)) {
                     log.error("FATAL: last response from AccountBalance update from Kafka ID was {}, but sent ID was {}",
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
index 0dc6ac3b9..66f61dfa0 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
@@ -90,6 +90,7 @@ public class ClearingService implements DisposableBean {
     public void continueClearing(BaseRequest<CommonIdRequest> event) {
         synchronized (clearing) {
             CommonIdRequest requestPayload = event.getRequestPayload();
+            log.debug("continueClearing for id={}", requestPayload.getId());
             clearing.setLastAccBalanceResponseId(requestPayload.getId());
             clearing.notifyAll();
         }