kamma/apicurio-migration-tool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

all apps created

Browse Source
This commit is contained in:
Radek Davidek 2025-11-07 08:30:04 +01:00
parent 5fa3786c89
commit 7c6a8aa50b
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/cz/trask/migration/impl/v45/ExportAppsToWso2FromV32.java
View File

@ -53,24 +53,25 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
executor.submit(() -> processApp(app, token, index, apps.getCount(), false)); executor.submit(() -> processApp(app, token, index, apps.getCount(), false));
} }
if (adminsDefaultApplication != null) {
log.info("Found default application for admins: {}", adminsDefaultApplication.getName());
executor.submit(() -> processApp(adminsDefaultApplication, token,
appCounter.getAndIncrement(), apps.getCount(), true));
}
executor.shutdown(); executor.shutdown();
if (!executor.awaitTermination(10, TimeUnit.MINUTES)) { if (!executor.awaitTermination(10, TimeUnit.MINUTES)) {
log.warn("Timeout waiting for App import tasks to finish"); log.warn("Timeout waiting for App import tasks to finish");
} }
log.info("Finished processing Apps."); log.info("Finished processing Apps.");
if (adminsDefaultApplication != null) {
log.info("Found default application for admins: {}", adminsDefaultApplication.getName());
processApp(adminsDefaultApplication, token,
appCounter.getAndIncrement(), apps.getCount(), true);
}
} catch (Exception e) { } catch (Exception e) {
log.error("Error while exporting Apps.", e); log.error("Error while exporting Apps.", e);
throw new RuntimeException("Export failed", e); throw new RuntimeException("Export failed", e);
} }
} }
private void processApp(SearchedArtifact app, TokenResponse tokenResponse, int index, int total, boolean createAdminApp) { private void processApp(SearchedArtifact app, TokenResponse tokenResponse, int index, int total,
boolean createAdminApp) {
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
try { try {
@ -90,7 +91,8 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
ApplicationDetail appDetail = mapper ApplicationDetail appDetail = mapper
.readValue(content, ApplicationDetail.class); .readValue(content, ApplicationDetail.class);
if (DEFAULT_APPLICATION_NAME.equals(appDetail.getName()) && ADMIN_USERNAME.equals(appDetail.getOwner()) && !createAdminApp) { if (DEFAULT_APPLICATION_NAME.equals(appDetail.getName())
&& ADMIN_USERNAME.equals(appDetail.getOwner()) && !createAdminApp) {
adminsDefaultApplication = app; adminsDefaultApplication = app;
deleteWso2ApplicationIfExists(appDetail, tokenResponse); deleteWso2ApplicationIfExists(appDetail, tokenResponse);
log.info(" - Skipping import of admins-default-application for now."); log.info(" - Skipping import of admins-default-application for now.");