Add another endpoint registry impl this time using the Hazelcast native client to connect to an existing domain hazelcast cluster

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@904111 13f79535-47bb-0310-9956-ffa450edef68

4 files changed, 148 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/META-INF/MANIFEST.MF b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/META-INF/MANIFEST.MF
new file mode 100644
index 0000000000..ea13b89d17
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/META-INF/MANIFEST.MF
@@ -0,0 +1,18 @@
+Manifest-Version: 1.0

+SCA-Version: 1.1

+Bundle-Name: Apache Tuscany SCA Hazelcast Client Based EndPoint Registry

+Bundle-Vendor: The Apache Software Foundation

+Bundle-Version: 2.0.0

+Bundle-ManifestVersion: 2

+Bundle-License: http://www.apache.org/licenses/LICENSE-2.0.txt

+Bundle-Description: Apache Tuscany Hazelcast Client Endpoint Regsitry

+Bundle-SymbolicName: org.apache.tuscany.sca.endpoint.hazelcast.client

+Bundle-DocURL: http://www.apache.org/

+Bundle-RequiredExecutionEnvironment: J2SE-1.5,JavaSE-1.6

+Import-Package: com.hazelcast.client,

+ org.apache.tuscany.sca.assembly;version="2.0.0",

+ org.apache.tuscany.sca.core;version="2.0.0",

+ org.apache.tuscany.sca.endpoint.hazelcast;version="2.0.0",

+ org.apache.tuscany.sca.runtime;version="2.0.0"

+Export-Package: org.apache.tuscany.sca.endpoint.hazelcast.client;version="2.0.0";

+ uses:="org.apache.tuscany.sca.runtime,org.apache.tuscany.sca.assembly,org.apache.tuscany.sca.core,org.apache.tuscany.sca.endpoint.hazelcast"

diff --git a/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/pom.xml b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/pom.xml
new file mode 100644
index 0000000000..4193d822e0
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/pom.xml
@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>

+<!--

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ *

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.

+-->

+<project>

+    <modelVersion>4.0.0</modelVersion>

+    <parent>

+        <groupId>org.apache.tuscany.sca</groupId>

+        <artifactId>tuscany-modules</artifactId>

+        <version>2.0-SNAPSHOT</version>

+        <relativePath>../pom.xml</relativePath>

+    </parent>

+    <artifactId>tuscany-endpoint-hazelcast-client</artifactId>

+    <name>Apache Tuscany SCA EndPoint Registry using Hazelcast Native Client</name>

+

+    <dependencies>

+        <dependency>

+            <groupId>com.hazelcast</groupId>

+            <artifactId>hazelcast-client</artifactId>

+            <version>1.8</version>

+        </dependency>

+        <dependency>

+            <groupId>org.apache.tuscany.sca</groupId>

+            <artifactId>tuscany-endpoint-hazelcast</artifactId>

+            <version>2.0-SNAPSHOT</version>

+            <scope>compile</scope>

+        </dependency>

+    </dependencies>

+

+</project>

diff --git a/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/client/HazelcastClientEndpointRegistry.java b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/client/HazelcastClientEndpointRegistry.java
new file mode 100644
index 0000000000..5ba660171e
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/client/HazelcastClientEndpointRegistry.java
@@ -0,0 +1,67 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ *

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.

+ */

+

+package org.apache.tuscany.sca.endpoint.hazelcast.client;

+

+import java.util.Map;

+

+import org.apache.tuscany.sca.core.ExtensionPointRegistry;

+import org.apache.tuscany.sca.endpoint.hazelcast.HazelcastEndpointRegistry;

+

+import com.hazelcast.client.HazelcastClient;

+

+/**

+ * An EndpointRegistry using a Hazelcast Native Client

+ */

+public class HazelcastClientEndpointRegistry extends HazelcastEndpointRegistry {

+

+    HazelcastClient hazelcastClient;

+

+    public HazelcastClientEndpointRegistry(ExtensionPointRegistry registry,

+                                     Map<String, String> attributes,

+                                     String domainRegistryURI,

+                                     String domainURI) {

+        super(registry, attributes, domainURI, domainRegistryURI);

+    }

+

+    @Override

+    public void start() {

+        if (map != null) {

+            throw new IllegalStateException("The registry has already been started");

+        }

+        initHazelcastClientInstance();

+        map = hazelcastClient.getMap(configURI.getDomainName() + "/Endpoints");

+    }

+

+    @Override

+    public void stop() {

+        if (hazelcastClient != null) {

+            hazelcastClient.shutdown();

+            hazelcastClient = null;

+            map = null;

+        }

+    }

+

+    private void initHazelcastClientInstance() {

+        if (configURI.getRemotes().size() < 1) {

+            throw new IllegalArgumentException("Must specify remote IP address(es) for domain");

+        }

+        this.hazelcastClient = HazelcastClient.newHazelcastClient(configURI.getDomainName(), configURI.getPassword(), configURI.getRemotes().toArray(new String[0]));

+    }

+}

diff --git a/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
new file mode 100644
index 0000000000..ca34978fe8
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/endpoint-hazelcast-client/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
@@ -0,0 +1,18 @@
+# Licensed to the Apache Software Foundation (ASF) under one

+# or more contributor license agreements.  See the NOTICE file

+# distributed with this work for additional information

+# regarding copyright ownership.  The ASF licenses this file

+# to you under the Apache License, Version 2.0 (the

+# "License"); you may not use this file except in compliance

+# with the License.  You may obtain a copy of the License at

+#

+#   http://www.apache.org/licenses/LICENSE-2.0

+#

+# Unless required by applicable law or agreed to in writing,

+# software distributed under the License is distributed on an

+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+# KIND, either express or implied.  See the License for the

+# specific language governing permissions and limitations

+# under the License.

+org.apache.tuscany.sca.endpoint.hazelcast.client.HazelcastClientEndpointRegistry;ranking=150,scheme=tuscanyClient

+