You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fineract.apache.org by ad...@apache.org on 2023/04/03 16:13:52 UTC

[fineract] branch develop updated: FINERACT-1724: Fixed storing the aggregate root ID for external events

This is an automated email from the ASF dual-hosted git repository.

adamsaghy pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/fineract.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6bdd6b1ac FINERACT-1724: Fixed storing the aggregate root ID for external events
6bdd6b1ac is described below

commit 6bdd6b1acead13d7176f6848aa2b8c0074091848
Author: Arnold Galovics <ga...@gmail.com>
AuthorDate: Mon Apr 3 16:05:11 2023 +0200

    FINERACT-1724: Fixed storing the aggregate root ID for external events
---
 .../event/external/jobs/SendAsynchronousEventsTasklet.java              | 2 +-
 .../infrastructure/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();