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();