Изменил директорию для уведомлений.
This commit is contained in:
parent
2f2d99e7ce
commit
d3fc4ae105
3 changed files with 11 additions and 1 deletions
|
|
@ -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;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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();
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue