treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Sdf10Executor опечатка в логе

Browse source 
GatewayRequester исключение
This commit is contained in:
ialbert 2023-09-11 19:51:10 +03:00
parent c4c2afe72c
commit 71cb78b72c
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf10Executor.java
View file

@ -254,7 +254,7 @@ public class Sdf10Executor {
) )
); );
if (stmt == null) { 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; return;
} }
requestIsIntendedForSdf10 = true; requestIsIntendedForSdf10 = true;

4
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/GatewayRequester.java
View file

@ -69,6 +69,10 @@ public class GatewayRequester extends QueueConsumer implements InitializingBean
boolean gatewayReceived = false; boolean gatewayReceived = false;
gatewayLock.lock(); gatewayLock.lock();
try { 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 //send Request
AssetOperationListRequest assetOperationListRequest = new AssetOperationListRequest(); AssetOperationListRequest assetOperationListRequest = new AssetOperationListRequest();
Collection<AssetOperationRequest> requests = new ArrayList<>(); Collection<AssetOperationRequest> requests = new ArrayList<>();