From b0d3e4ac5a9917498c047e6346ad4b89ed79e62f Mon Sep 17 00:00:00 2001 From: ialbert Date: Mon, 3 Oct 2022 15:33:51 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-65 --- .../spcex/clearing/utility/service/UserSettingService.java | 5 ++++- .../src/main/resources/application.properties | 4 ++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/UserSettingService.java b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/UserSettingService.java index 726580197..f34af7255 100644 --- a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/UserSettingService.java +++ b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/UserSettingService.java @@ -41,16 +41,19 @@ public class UserSettingService extends QueueConsumer implements InitializingBea log.debug("UserSettingsUpdateRequest received userId = {}", req.getUserId()); UserSettings settings = userSettingsMap.getSingleObjectByFieldValues(Map.of("userId", req.getUserId())); if (settings != null) { - log.debug("found user settings for userId={}, id={}", req.getUserId(), settings.getId()); + log.debug("found user settings for userId={}, id={}...", req.getUserId(), settings.getId()); settings.setVersion(req.getVersion()); settings.setJson(req.getJson()); userSettingsMap.update(settings); + log.debug("updated user settings for userId={}, id={}", req.getUserId(), settings.getId()); } else { + log.debug("creating user settings for userId={}...", req.getUserId()); settings = new UserSettings(); settings.setUserId(req.getUserId()); settings.setVersion(req.getVersion()); settings.setJson(req.getJson()); userSettingsMap.insert(settings); + log.debug("created user settings for userId={}, id={}", req.getUserId(), settings.getId()); } } } diff --git a/clearing-parent/utility-service/src/main/resources/application.properties b/clearing-parent/utility-service/src/main/resources/application.properties index 2b0952cfc..fbc306eab 100644 --- a/clearing-parent/utility-service/src/main/resources/application.properties +++ b/clearing-parent/utility-service/src/main/resources/application.properties @@ -1,12 +1,12 @@ spring.main.web-application-type=none -utility-service.hazelcast.cluster-members=127.0.0.1:5071 +utility-service.hazelcast.cluster-members=127.0.0.1:5701 utility-service.hazelcast.login=dev utility-service.hazelcast.password=dev-pass utility-service.kafka.bootstrap-servers=localhost:9092 utility-service.kafka.group-id=dev-group-utility-service -utility-service.kafka.enable-auto-commit=false +utility-service.kafka.enable-auto-commit=true utility-service.kafka.session-timeout-ms=30000 utility-service.kafka.auto-offset-reset=latest utility-service.kafka.linger-ms=1