midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1001804 Issue about cache with load balancer. Use hazelcast.xml from IDEMPIERE_HOME if available.

This commit is contained in:
Heng Sin Low 2012-12-19 18:18:26 +08:00
parent 4d6203f007
commit 095aa76714
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
org.idempiere.hazelcast.service/src/org/idempiere/hazelcast/service/Activator.java
View File

@ -13,6 +13,10 @@
*****************************************************************************/ *****************************************************************************/
package org.idempiere.hazelcast.service; package org.idempiere.hazelcast.service;
import java.io.File;
import java.io.FileNotFoundException;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ScheduledThreadPoolExecutor;
@ -24,6 +28,8 @@ import org.compiere.model.ServerStateChangeListener;
import org.osgi.framework.BundleActivator; import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext; import org.osgi.framework.BundleContext;
import com.hazelcast.config.Config;
import com.hazelcast.config.FileSystemXmlConfig;
import com.hazelcast.core.*; import com.hazelcast.core.*;
/** /**
@ -68,6 +74,21 @@ public class Activator implements BundleActivator {
Future<?> future = executor.submit(new Runnable() { Future<?> future = executor.submit(new Runnable() {
@Override @Override
public void run() { public void run() {
String dataArea = System.getProperty("osgi.install.area");
if (dataArea != null && dataArea.trim().length() > 0) {
try {
URL url = new URL(dataArea);
File file = new File(url.getPath(), "hazelcast.xml");
if (file.exists()) {
try {
Config config = new FileSystemXmlConfig(file);
hazelcastInstance = Hazelcast.newHazelcastInstance(config);
return;
} catch (FileNotFoundException e) {}
}
} catch (MalformedURLException e1) {
}
}
hazelcastInstance = Hazelcast.newHazelcastInstance(null); hazelcastInstance = Hazelcast.newHazelcastInstance(null);
} }
}); });