From 6bdd6b1acead13d7176f6848aa2b8c0074091848 Mon Sep 17 00:00:00 2001 From: Arnold Galovics Date: Mon, 3 Apr 2023 16:05:11 +0200 Subject: [PATCH] FINERACT-1724: Fixed storing the aggregate root ID for external events --- .../event/external/jobs/SendAsynchronousEventsTasklet.java | 2 +- .../event/external/repository/domain/ExternalEvent.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/jobs/SendAsynchronousEventsTasklet.java b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/jobs/SendAsynchronousEventsTasklet.java index 699609729..e092bcebf 100644 --- a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/jobs/SendAsynchronousEventsTasklet.java +++ b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/jobs/SendAsynchronousEventsTasklet.java @@ -135,7 +135,7 @@ public class SendAsynchronousEventsTasklet implements Tasklet { ByteBuffer toByteBuffer = message.toByteBuffer(); byte[] convert = byteBufferConverter.convert(toByteBuffer); messages.add(convert); - log.debug("Created message to send with id: [{}], type: [{}], idempotency key: [{}]", message.getId(), message.getType(), + log.trace("Created message to send with id: [{}], type: [{}], idempotency key: [{}]", message.getId(), message.getType(), message.getIdempotencyKey()); } return messages; diff --git a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/repository/domain/ExternalEvent.java b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/repository/domain/ExternalEvent.java index 5e3802117..a771fa812 100644 --- a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/repository/domain/ExternalEvent.java +++ b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/repository/domain/ExternalEvent.java @@ -79,6 +79,7 @@ public class ExternalEvent extends AbstractPersistableCustom { this.schema = schema; this.data = data; this.idempotencyKey = idempotencyKey; + this.aggregateRootId = aggregateRootId; this.createdAt = DateUtils.getOffsetDateTimeOfTenantWithMilliseconds(); this.status = ExternalEventStatus.TO_BE_SENT; this.businessDate = DateUtils.getBusinessLocalDate();