Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
aomegax committed Jan 2, 2024
1 parent 3ebae3d commit da17410
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public void processNodoVerifyKOEvent (

Logger logger = context.getLogger();
logger.log(Level.INFO, () -> String.format("Persisting [%d] events...", events.size()));

String rowKey = "";
try {
if (events.size() == properties.length) {
Map<String, List<TableTransactionAction>> partitionedEvents = new HashMap<>();
Expand Down Expand Up @@ -84,7 +84,7 @@ public void processNodoVerifyKOEvent (
String insertedDateValue = dateTime.getYear() + "-" + dateTime.getMonthValue() + "-" + dateTime.getDayOfMonth();

// inserting the identification columns on event saved in Table Storage
String rowKey = generateRowKey(event, String.valueOf(timestamp));
rowKey = generateRowKey(event, String.valueOf(timestamp));
eventToBeStored.put(Constants.PARTITION_KEY_TABLESTORAGE_EVENT_FIELD, insertedDateValue);
eventToBeStored.put(Constants.ROW_KEY_TABLESTORAGE_EVENT_FIELD, rowKey);

Expand All @@ -107,7 +107,8 @@ public void processNodoVerifyKOEvent (
logger.log(Level.SEVERE, () -> String.format("[ALERT][VerifyKOToTS] AppException - Error processing events, lengths do not match: [events: %d - properties: %d]", events.size(), properties.length));
}
} catch (BlobStorageUploadException e) {
logger.log(Level.SEVERE, () -> "[ALERT][VerifyKOToTS] Persistence Exception - Could not save event body on Azure Blob Storage, error: " + e);
String finalRowKey = rowKey;
logger.log(Level.SEVERE, () -> "[ALERT][VerifyKOToTS] Persistence Exception - Could not save event body of " + finalRowKey + " on Azure Blob Storage, error: " + e);
} catch (IllegalArgumentException e) {
logger.log(Level.SEVERE, () -> "[ALERT][VerifyKOToDS] AppException - Illegal argument exception on table storage nodo-verify-ko-events msg ingestion at " + LocalDateTime.now() + " : " + e);
} catch (IllegalStateException e) {
Expand Down

0 comments on commit da17410

Please sign in to comment.