Revision 3f87d726
Added by Katja Luther over 4 years ago
app-import/src/main/java/eu/etaxonomy/cdm/app/common/tasks/CacheUpdater.java | ||
---|---|---|
11 | 11 |
|
12 | 12 |
import java.util.Arrays; |
13 | 13 |
import java.util.List; |
14 |
import java.util.UUID; |
|
14 | 15 |
|
15 | 16 |
import org.apache.log4j.Logger; |
16 | 17 |
|
18 |
import eu.etaxonomy.cdm.api.application.CdmApplicationController; |
|
17 | 19 |
import eu.etaxonomy.cdm.api.service.config.CacheUpdaterConfigurator; |
18 | 20 |
import eu.etaxonomy.cdm.app.common.CdmDestinations; |
21 |
import eu.etaxonomy.cdm.common.monitor.IRemotingProgressMonitor; |
|
22 |
import eu.etaxonomy.cdm.database.DbSchemaValidation; |
|
19 | 23 |
import eu.etaxonomy.cdm.database.ICdmDataSource; |
24 |
import eu.etaxonomy.cdm.io.api.application.CdmIoApplicationController; |
|
20 | 25 |
import eu.etaxonomy.cdm.io.common.CdmDefaultImport; |
21 | 26 |
import eu.etaxonomy.cdm.io.common.ImportResult; |
22 | 27 |
|
... | ... | |
64 | 69 |
|
65 | 70 |
CacheUpdaterConfigurator config; |
66 | 71 |
try { |
67 |
config = CacheUpdaterConfigurator.NewInstance(destination, classListStrings);
|
|
72 |
config = CacheUpdaterConfigurator.NewInstance( classListStrings); |
|
68 | 73 |
|
69 | 74 |
// invoke import |
70 |
CdmDefaultImport<CacheUpdaterConfigurator> myImport = new CdmDefaultImport<>(); |
|
71 |
result = myImport.invoke(config); |
|
75 |
CdmApplicationController appCtrInit = CdmIoApplicationController.NewInstance(destination, DbSchemaValidation.VALIDATE, false); |
|
76 |
appCtrInit.authenticate("admin", "kups366+RU"); |
|
77 |
UUID monitUuid = appCtrInit.getLongRunningTasksService().monitLongRunningTask(config); |
|
78 |
IRemotingProgressMonitor monitor = appCtrInit.getProgressMonitorService().getRemotingMonitor(monitUuid); |
|
79 |
while(monitor != null && (!monitor.isCanceled() || !monitor.isDone() || !monitor.isFailed())) { |
|
80 |
try { |
|
81 |
Thread.sleep(10); |
|
82 |
} catch (InterruptedException e) { |
|
83 |
// TODO Auto-generated catch block |
|
84 |
e.printStackTrace(); |
|
85 |
} |
|
86 |
logger.info("Waiting for monitered work to start .."); |
|
87 |
monitor = appCtrInit.getProgressMonitorService().getRemotingMonitor(monitUuid); |
|
88 |
} |
|
72 | 89 |
//String successString = success ? "successful" : " with errors "; |
73 | 90 |
//System.out.println("End updating caches for "+ destination.getDatabase() + "..." + successString); |
74 | 91 |
return result; |
Also available in: Unified diff
fix compile errors in app-import