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 requests = new ArrayList<>();