StatementService SDF types restriction

This commit is contained in:
ialbert 2023-08-08 16:25:13 +03:00
parent 33e75e6e81
commit 6740c4ed23

View file

@ -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 {