From 269642fbad90551e189764e3da81e61e6ab07750 Mon Sep 17 00:00:00 2001
From: Rustam_Lotsmanenko <rustam_lotsmanenko@epam.com>
Date: Wed, 1 Feb 2023 13:14:06 +0200
Subject: [PATCH] minor log fix
---
.../processing/IndexerOqmMessageReceiver.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 deletions(-)
diff --git a/provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiver.java b/provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiver.java
index 3d19f8e6f..973372f43 100644
--- a/provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiver.java
+++ b/provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiver.java
@@ -60,8 +60,7 @@ public abstract class IndexerOqmMessageReceiver implements OqmMessageReceiver {
int statusCode = appException.getError().getCode();
if (statusCode > 199 && statusCode < 300 && statusCode != RequestStatus.INVALID_RECORD) {
log.info(
- "Event : {}, was not processed, and will NOT be rescheduled.",
- oqmMessage,
+ "Event id : " + oqmMessage.getId() + ", was not processed, and will NOT be rescheduled.",
appException
);
acked = true;
@@ -69,16 +68,15 @@ public abstract class IndexerOqmMessageReceiver implements OqmMessageReceiver {
//It is possible to get both AppException with wrapped in original Exception or the original Exception without any wrapper
Exception exception = Optional.ofNullable(appException.getOriginalException()).orElse(appException);
log.warn(
- "Event : {}, was not processed, and will BE rescheduled.",
- oqmMessage,
+ "Event id : " + oqmMessage.getId() + ", was not processed, and will BE rescheduled.",
exception
);
}
} catch (Exception exception) {
log.error(
- "Error, Event : {}, was not processed, and will BE rescheduled.",
- oqmMessage,
- exception);
+ "Event id : " + oqmMessage.getId() + ", was not processed, and will BE rescheduled.",
+ exception
+ );
} finally {
if (!acked) {
oqmAckReplier.nack();
--
GitLab