treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-65

Browse source
This commit is contained in:
ialbert 2022-10-03 15:33:51 +03:00
parent 6120849cd2
commit b0d3e4ac5a
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/UserSettingService.java
View file

@ -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());
}
}
}

4
clearing-parent/utility-service/src/main/resources/application.properties
View file

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