CBSNexora/cbsnexora-backend
4
0
Fork 0
Code Issues Pull Requests Actions 19 Packages Projects Releases Wiki Activity

FINERACT-1724: Fixed storing the aggregate root ID for external events

Browse Source
This commit is contained in:
Arnold Galovics
2023-04-03 18:13:45 +02:00
committed by Adam Saghy
parent 94105f26e6
commit 6bdd6b1ace
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/jobs/SendAsynchronousEventsTasklet.java
Vendored
+1 -1
View File
@@ -135,7 +135,7 @@ public class SendAsynchronousEventsTasklet implements Tasklet {
ByteBuffer toByteBuffer = message.toByteBuffer(); ByteBuffer toByteBuffer = message.toByteBuffer();
byte[] convert = byteBufferConverter.convert(toByteBuffer); byte[] convert = byteBufferConverter.convert(toByteBuffer);
messages.add(convert); 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()); message.getIdempotencyKey());
} }
return messages; return messages;
fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/repository/domain/ExternalEvent.java
Vendored
+1
View File
@@ -79,6 +79,7 @@ public class ExternalEvent extends AbstractPersistableCustom {
this.schema = schema; this.schema = schema;
this.data = data; this.data = data;
this.idempotencyKey = idempotencyKey; this.idempotencyKey = idempotencyKey;
this.aggregateRootId = aggregateRootId;
this.createdAt = DateUtils.getOffsetDateTimeOfTenantWithMilliseconds(); this.createdAt = DateUtils.getOffsetDateTimeOfTenantWithMilliseconds();
this.status = ExternalEventStatus.TO_BE_SENT; this.status = ExternalEventStatus.TO_BE_SENT;
this.businessDate = DateUtils.getBusinessLocalDate(); this.businessDate = DateUtils.getBusinessLocalDate();