diff --git a/armonik-client/src/main/java/fr/aneo/armonik/client/internal/grpc/observers/DownloadBlobDataObserver.java b/armonik-client/src/main/java/fr/aneo/armonik/client/internal/grpc/observers/DownloadBlobDataObserver.java index 5111940..2d58dda 100644 --- a/armonik-client/src/main/java/fr/aneo/armonik/client/internal/grpc/observers/DownloadBlobDataObserver.java +++ b/armonik-client/src/main/java/fr/aneo/armonik/client/internal/grpc/observers/DownloadBlobDataObserver.java @@ -80,26 +80,16 @@ public void onNext(DownloadResultDataResponse chunk) { @Override public void onError(Throwable throwable) { - logger.atError() - .addKeyValue("operation", "downloadBlob") - .addKeyValue("sessionId", sessionId.asString()) - .addKeyValue("blobId", blobId.asString()) - .addKeyValue("error", throwable.getClass().getSimpleName()) - .setCause(throwable) - .log("Blob download failed"); - + logger.error("Blob download failed: operation={}, sessionId={}, blobId={}, error={}", + "downloadBlob", sessionId.asString(), blobId.asString(), throwable.getClass().getSimpleName(), + throwable); result.setException(throwable); } @Override public void onCompleted() { - logger.atDebug() - .addKeyValue("operation", "downloadBlob") - .addKeyValue("sessionId", sessionId.asString()) - .addKeyValue("blobId", blobId.asString()) - .addKeyValue("downloadSize", buffer.size()) - .log("Blob download completed"); - + logger.debug("Blob download completed: operation={}, sessionId={}, blobId={}, downloadSize={}", + "downloadBlob", sessionId.asString(), blobId.asString(), buffer.size()); result.set(buffer.toByteArray()); }