diff --git a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java index f6c00556b..a3e42f850 100644 --- a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java +++ b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java @@ -128,7 +128,7 @@ public class TaskListener extends QueueConsumer implements InitializingBean { log.warn("Unsupported overnightType={} for registry id={}", overnightType, registry.getId()); } } catch (Exception e) { - log.error("Error while processing registryId={}", registryId, e); + log.error("Error while processing registryId={}, ex: {}", registryId, ExceptionUtils.getStackTrace(e)); } } log.info("CROR createOrder finished"); @@ -157,20 +157,20 @@ public class TaskListener extends QueueConsumer implements InitializingBean { kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, newReq); } - log.info("export to tri..."); try { + log.info("export to tri..."); Collection orders = imdgQueryService.getClccOrderCurrencyIds(); String content = orderCurrencyTriExportService.exportToTri(orders); Path fileName = storagePath.resolve(String.format("KS_TS_ORDERS_%s.tri", LocalDateTime.now().format(formatter))); Files.writeString(fileName, content, winCharset); - if (SendOrdersTypes.FIX == sendOrdersTypes) { - log.info("send command to fix service..."); - kafkaSender.sendRequestToQueue(Consts.SDOR_FIX_TASK, req.getRequestPayload()); - } } catch (IOException e) { log.error("Error while import order currency to tri file: {}", ExceptionUtils.getStackTrace(e)); } + if (SendOrdersTypes.FIX == sendOrdersTypes) { + log.info("send command to fix service..."); + kafkaSender.sendRequestToQueue(Consts.SDOR_FIX_TASK, req.getRequestPayload()); + } } private String checkBalance(OrderCurrency orderCurrency) {