From 71cb78b72c6aaf849e071c55ff228eb3c4ca0588 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Mon, 11 Sep 2023 19:51:10 +0300
Subject: [PATCH] =?UTF-8?q?Sdf10Executor=20=D0=BE=D0=BF=D0=B5=D1=87=D0=B0?=
 =?UTF-8?q?=D1=82=D0=BA=D0=B0=20=D0=B2=20=D0=BB=D0=BE=D0=B3=D0=B5=20Gatewa?=
 =?UTF-8?q?yRequester=20=D0=B8=D1=81=D0=BA=D0=BB=D1=8E=D1=87=D0=B5=D0=BD?=
 =?UTF-8?q?=D0=B8=D0=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ru/spcex/clearing/service/executors/Sdf10Executor.java    | 2 +-
 .../spcex/clearing/session/stage/impl/GatewayRequester.java   | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf10Executor.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf10Executor.java
index a51324528..2ee0a33d3 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf10Executor.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf10Executor.java
@@ -254,7 +254,7 @@ public class Sdf10Executor {
                     )
             );
             if (stmt == null) {
-                log.debug("Statement.id {} with type {} not found", statementId, InOutSDfType.type6.getKey());
+                log.debug("Statement.id {} with type {} not found", statementId, InOutSDfType.type10.getKey());
                 return;
             }
             requestIsIntendedForSdf10 = true;
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/GatewayRequester.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/GatewayRequester.java
index 639d7ff99..59358851d 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/GatewayRequester.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/GatewayRequester.java
@@ -69,6 +69,10 @@ public class GatewayRequester extends QueueConsumer implements InitializingBean
         boolean gatewayReceived = false;
         gatewayLock.lock();
         try {
+            if (this.omtId != null) {
+                log.error("om*t.id={} already sent to gateway", this.omtId);
+                throw new IllegalStateException(" forbid reusing GatewayRequester instance in multiple threads");
+            }
             //send Request
             AssetOperationListRequest assetOperationListRequest = new AssetOperationListRequest();
             Collection<AssetOperationRequest> requests = new ArrayList<>();