From dfe3e271d75ff5984c2d5d4bf07bd9d1584c0887 Mon Sep 17 00:00:00 2001 From: AKurakin Date: Tue, 4 Jul 2023 14:22:32 +0300 Subject: [PATCH] =?UTF-8?q?backend-api=20=D0=BB=D0=BE=D0=B3=D0=B8=D1=80?= =?UTF-8?q?=D0=BE=D0=B2=D0=B0=D0=BD=D0=B8=D0=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../backendapi/controller/test/KafkaApiController.java | 1 + .../spcex/clearing/backendapi/service/impl/OperatorImpl.java | 5 ++++- .../backend-api/src/main/resources/application.properties | 4 ++++ 3 files changed, 9 insertions(+), 1 deletion(-) diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java index 335e0025f..026302e97 100644 --- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java +++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java @@ -49,6 +49,7 @@ public class KafkaApiController { JavaType requestType = json.getTypeFactory().constructSimpleType(parameterType, null); Object obj = json.readValue(bankAccountNewAction.getJson(), requestType); Long idOfBaseRequestMessage = kafkaSender.sendRequestToQueue(bankAccountNewAction.getTopicName(), obj); + log.debug("Test message to topic {} with request id={}", bankAccountNewAction.getTopicName(), idOfBaseRequestMessage); return "success: baseRequest.id = " + idOfBaseRequestMessage; } diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java index 009d24485..d23513302 100644 --- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java +++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java @@ -82,6 +82,7 @@ public class OperatorImpl implements IOperator { saveRequestToStorage(destination, request); Future send = kafka.send(new ProducerRecord<>(destination, request)); send.get(); + log.debug("Request id={} by user {} send to queue \"{}\". Action: {}", request.getId(), request.getUserId(), destination, iAction); return new QueueSuccessResponse(request.getActionType(), request.getId()); } @@ -101,13 +102,15 @@ public class OperatorImpl implements IOperator { saveRequestToStorage(destination, request); Future send = kafka.send(new ProducerRecord<>(destination, request)); send.get(); + log.debug("Request id={} by user {} send to queue \"{}\". Action: {}", request.getId(), userId, destination, iAction); return new QueueSuccessResponse(request.getActionType(), request.getId()); } private void saveRequestToStorage(String destination, BaseRequest request) { Imdg requestStorage = imdgProvider.getImdg(IMDGDistributedNames.Map_RequestInfo, RequestInfo.class); RequestInfo requestInfo = RequestInfo.create(request.getId()); - requestStorage.insert(requestInfo); + Long storeId = requestStorage.insert(requestInfo); + log.trace("Request id={} saved as RequestInfo with id={}", request.getId(), storeId); } private void throwValidate(String destination, IAction iAction) { diff --git a/clearing-parent/backend-api/src/main/resources/application.properties b/clearing-parent/backend-api/src/main/resources/application.properties index bbbcc6022..29cf01fe5 100644 --- a/clearing-parent/backend-api/src/main/resources/application.properties +++ b/clearing-parent/backend-api/src/main/resources/application.properties @@ -23,6 +23,10 @@ backend-api.kafka-consumer.auto-offset-reset=latest backend-api.kafka-consumer.linger-ms=1 backend-api.kafka-consumer.buffer-memory=33554432 backend-api.security.authorization-disabled=false +#access logs, sample +#server.tomcat.accesslog.directory=logs +#server.tomcat.accesslog.enabled=true +#server.tomcat.accesslog.pattern=%h %l %u %t \"%r\" %>s %b ##keycloak ##keycloak.auth-server-url=http://10.200.200.147:8080/ ##keycloak.realm=master