gCubeSystem
/
is-registry
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Asynch creation of the factory resource 

git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/information-system/gCubeIS/Registry@34689 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Manuele Simi 2011-02-05 20:41:01 +00:00
parent 99ee7ae64d
commit f97788792f
1 changed files with 22 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/org/gcube/informationsystem/registry/impl/porttypes/RegistryFactory.java
View File

@ -67,18 +67,28 @@ public class RegistryFactory extends GCUBEPortType {
if (singletonResource != null) if (singletonResource != null)
return;//cannot create the state twice return;//cannot create the state twice
logger.info("Initialising the factory state..."); logger.info("Initialising the factory state...");
try { new Thread() {
for (GCUBEScope scope: ServiceContext.getContext().getInstance().getScopes().values()){
logger.info("Creating the notification resource " + RegistryFactory.NOTIFICATOR_RESOURCE_KEY + " within the scope " + scope.getName()); @Override
ServiceContext.getContext().setScope(scope); public void run() {
singletonResource = (RegistryFactoryResource) FactoryContext.getContext().getWSHome().create(FactoryContext.getContext().makeKey(RegistryFactory.NOTIFICATOR_RESOURCE_KEY)); while (true) {
singletonResource.store(); try {
for (GCUBEScope scope: ServiceContext.getContext().getInstance().getScopes().values()){
RegistryFactory.logger.info("Creating the notification resource " + RegistryFactory.NOTIFICATOR_RESOURCE_KEY + " within the scope " + scope.getName());
ServiceContext.getContext().setScope(scope);
singletonResource = (RegistryFactoryResource) FactoryContext.getContext().getWSHome().create(FactoryContext.getContext().makeKey(RegistryFactory.NOTIFICATOR_RESOURCE_KEY));
singletonResource.store();
}
break;
} catch (Exception e) {
RegistryFactory.logger.error("Failed to create the resource", e);
Thread.sleep(1000);
}
}
} }
} catch (Exception e) { }.start();
logger.error("Failed to create the resource", e);
throw e;
}
} }