Hi,
I’m upgrading axon 2 to axon 4 in out project. Most of changing are made. I know in new axon framework we expect globleIndex in DomainEventEntry table. It’s unique index. Since we already have 200 million data in production table. It’s impossible to add this new column. So we decide to have a new table start to fresh, all projects have new axon are going to add to new table, the projects not upgrade yet so still can go to old table.
Then the problem is data migration. We are going to adding data to the new table. Everying working fine if we have the data in SnapEventEntry. But if we don’t have data in SnapEventEntry (config 100 events add/update snapshot), then we get AggregateNotFoundException which is ok. We want to add this event as first data in the new table. Do we have a way to catch this exception and do my logic from framework level? I don’t want to add same logic in every gateway send command method.
I tried to use @ExceptionHandler inside Aggregate, but not go to my logic in debug mode.
Application code:
gateway.updateSecurityQuestionAccount(updateSecurityQuestionAccountCommand);
CommandHandler
@CommandHandler
public void handleUpdateSecurityQuestionAccount(UpdateSecurityQuestionAccountCommand command) {
load(command.getId(), aggregate → {
aggregate.updateSecurityQuestionAccount(
command.getQuestions()
);
});
}
Load method in base command handler, I tried to catch the exception here but not work
protected final void load(J id, Consumer consumer) {
repository.load(String.valueOf(id)).execute(consumer);
}
Aggregate
@Aggregate
public class PersonAggregateRoot {
public void updateSecurityQuestionAccount(List questions) {
AggregateLifecycle.apply(new SecurityQuestionAccountUpdatedEvent(id, realm, creator, creatorAppId, creation, questions));
}
}