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

backend-api логирование

Browse source
This commit is contained in:
AKurakin 2023-07-04 14:22:32 +03:00
parent e25b8c771f
commit dfe3e271d7
3 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/test/KafkaApiController.java
View file

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

5
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/service/impl/OperatorImpl.java
View file

@ -82,6 +82,7 @@ public class OperatorImpl implements IOperator {
saveRequestToStorage(destination, request);
Future<RecordMetadata> 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<RecordMetadata> 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<Object> request) {
Imdg<RequestInfo> 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) {

4
clearing-parent/backend-api/src/main/resources/application.properties
View file

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