diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java index 04cc4249b..b712a77ea 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java @@ -67,6 +67,11 @@ public class StatementService extends QueueConsumer implements InitializingBean callback(StatementRequest.class) .setConsumer(systemRequest -> { StatementRequest payload = systemRequest.getRequestPayload(); + if (payload.getTable() == null + || !Arrays.asList(SdfTable.SDF_01, SdfTable.SDF_57, SdfTable.SDF_08, SdfTable.SDF_13).contains(payload.getTable())) { + log.debug("StatementService: skipping table {}", payload.getTable()); + return; + } if (payload.isContinueSdf()) { processAccountAnswer(systemRequest); } else {