From d3fc4ae105c0392daf8042cb1734d16c9e3b921c Mon Sep 17 00:00:00 2001 From: psemenkov Date: Wed, 7 Jun 2023 17:00:39 +0300 Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-321=20?= =?UTF-8?q?=D0=98=D0=B7=D0=BC=D0=B5=D0=BD=D0=B8=D0=BB=20=D0=B4=D0=B8=D1=80?= =?UTF-8?q?=D0=B5=D0=BA=D1=82=D0=BE=D1=80=D0=B8=D1=8E=20=D0=B4=D0=BB=D1=8F?= =?UTF-8?q?=20=D1=83=D0=B2=D0=B5=D0=B4=D0=BE=D0=BC=D0=BB=D0=B5=D0=BD=D0=B8?= =?UTF-8?q?=D0=B9.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reports/config/element/ReportsServiceSettings.java | 9 +++++++++ .../clearing/reports/services/NotificationService.java | 2 +- .../src/main/resources/application.properties | 1 + 3 files changed, 11 insertions(+), 1 deletion(-) diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/element/ReportsServiceSettings.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/element/ReportsServiceSettings.java index 365eafeb8..ec52a7c55 100644 --- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/element/ReportsServiceSettings.java +++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/element/ReportsServiceSettings.java @@ -15,6 +15,7 @@ public class ReportsServiceSettings { private KafkaConsumerSettings kafkaConsumer; private KafkaProducerSettings kafkaProducer; private String reportModuleOut; + private String notificationModuleOut; public HazelcastClientParams getHazelcast() { return hazelcast; @@ -47,4 +48,12 @@ public class ReportsServiceSettings { public void setReportModuleOut(String reportModuleOut) { this.reportModuleOut = reportModuleOut; } + + public String getNotificationModuleOut() { + return notificationModuleOut; + } + + public void setNotificationModuleOut(String notificationModuleOut) { + this.notificationModuleOut = notificationModuleOut; + } } diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/NotificationService.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/NotificationService.java index 64ef52bc0..4bc8b0cc2 100644 --- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/NotificationService.java +++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/NotificationService.java @@ -34,7 +34,7 @@ public class NotificationService extends QueueConsumer implements InitializingBe super(kafkaQueue, kafkaResponseQueue); this.userRoleVerification = userRoleVerification; this.ncmpNotificationBuilder = ncmpNotificationBuilder; - this.outFolder = new File(reportsServiceSettings.getReportModuleOut()); + this.outFolder = new File(reportsServiceSettings.getNotificationModuleOut()); assert outFolder.isDirectory(); } diff --git a/clearing-parent/reports-service/src/main/resources/application.properties b/clearing-parent/reports-service/src/main/resources/application.properties index fdf19a25d..82290ecaa 100644 --- a/clearing-parent/reports-service/src/main/resources/application.properties +++ b/clearing-parent/reports-service/src/main/resources/application.properties @@ -18,3 +18,4 @@ reports-service.kafka-producer.linger-ms=1 reports-service.kafka-producer.buffer-memory=33554432 reports-service.ReportModuleOut=./report_out +reports-service.NotificationModuleOut=./notification_out