You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by an...@apache.org on 2010/01/08 10:24:03 UTC
svn commit: r897140 - in
/tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast:
ConfigURI.java HazelcastEndpointRegistry.java
Author: antelder
Date: Fri Jan 8 09:24:02 2010
New Revision: 897140
URL: http://svn.apache.org/viewvc?rev=897140&view=rev
Log:
Change the Hazelcast registry to support both distributed an in-VM only operation
Modified:
tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/ConfigURI.java
tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
Modified: tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/ConfigURI.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/ConfigURI.java?rev=897140&r1=897139&r2=897140&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/ConfigURI.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/ConfigURI.java Fri Jan 8 09:24:02 2010
@@ -51,8 +51,10 @@
private String multicastAddress = "224.5.12.10";
private int multicastPort = 51482;
private List<String> remotes = new ArrayList<String>();
+ private String uri;
public ConfigURI(String uri) {
+ this.uri = uri;
parseURI(uri);
}
@@ -154,5 +156,9 @@
public List<String> getRemotes() {
return remotes;
}
+
+ public String toString() {
+ return uri;
+ }
}
Modified: tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java?rev=897140&r1=897139&r2=897140&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java Fri Jan 8 09:24:02 2010
@@ -21,6 +21,7 @@
import java.net.UnknownHostException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArrayList;
@@ -39,7 +40,6 @@
import com.hazelcast.config.XmlConfigBuilder;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.core.IMap;
import com.hazelcast.nio.Address;
/**
@@ -55,7 +55,7 @@
private ConfigURI configURI;
private HazelcastInstance hazelcastInstance;
- private IMap<Object, Object> map;
+ private Map<Object, Object> map;
private List<String> localEndpoints = new ArrayList<String>();;
public HazelcastEndpointRegistry(ExtensionPointRegistry registry,
@@ -70,12 +70,16 @@
if (map != null) {
throw new IllegalStateException("The registry has already been started");
}
- initHazelcastInstance();
- map = hazelcastInstance.getMap(configURI.getDomainName() + "Endpoints");
+ if (configURI.toString().startsWith("tuscany:vm:")) {
+ map = new HashMap<Object, Object>();
+ } else {
+ initHazelcastInstance();
+ map = hazelcastInstance.getMap(configURI.getDomainName() + "Endpoints");
+ }
}
public void stop() {
- if (map != null) {
+ if (hazelcastInstance != null) {
hazelcastInstance.shutdown();
}
}
@@ -187,7 +191,7 @@
if (endpointReference.getReference() != null) {
Endpoint targetEndpoint = endpointReference.getTargetEndpoint();
-
+
for (Object v : map.values()) {
Endpoint endpoint = (Endpoint)v;
logger.fine("Matching against - " + endpoint);