From 3c55d4251e24be7615327926966bd930212166b7 Mon Sep 17 00:00:00 2001 From: antelder Date: Sat, 2 Jan 2010 10:29:34 +0000 Subject: Another registry impl! this time trying Hazelcast git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@895166 13f79535-47bb-0310-9956-ffa450edef68 --- sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF | 28 +++++++ sandbox/endpoint-hazelcast/pom.xml | 63 ++++++++++++++ ...org.apache.tuscany.sca.runtime.EndpointRegistry | 17 ++++ .../sca/endpoint/hazelcast/RegistryTestCase.java | 98 ++++++++++++++++++++++ 4 files changed, 206 insertions(+) create mode 100644 sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF create mode 100644 sandbox/endpoint-hazelcast/pom.xml create mode 100644 sandbox/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry create mode 100644 sandbox/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java (limited to 'sandbox') diff --git a/sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF b/sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF new file mode 100644 index 0000000000..06df55ef38 --- /dev/null +++ b/sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF @@ -0,0 +1,28 @@ +Manifest-Version: 1.0 +Private-Package: org.apache.tuscany.sca.xsd.impl;version="2.0.0" +SCA-Version: 1.1 +Bundle-Name: Apache Tuscany SCA Tomcat Tribes 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 SCA XSD Model +Bundle-SymbolicName: org.apache.tuscany.sca.endpoint.tribes +Bundle-DocURL: http://www.apache.org/ +Bundle-RequiredExecutionEnvironment: J2SE-1.5,JavaSE-1.6 +Import-Package: org.apache.catalina.tribes, + org.apache.catalina.tribes.group, + org.apache.catalina.tribes.group.interceptors, + org.apache.catalina.tribes.io, + org.apache.catalina.tribes.membership, + org.apache.catalina.tribes.tipis, + org.apache.catalina.tribes.transport, + org.apache.catalina.tribes.util, + org.apache.juli.logging;resolution:=optional, + org.apache.tuscany.sca.assembly;version="2.0.0", + org.apache.tuscany.sca.core;version="2.0.0", + org.apache.tuscany.sca.core.assembly.impl;scope=internal;version="2.0.0";resolution:=optional, + org.apache.tuscany.sca.management;version="2.0.0", + org.apache.tuscany.sca.policy;version="2.0.0", + org.apache.tuscany.sca.runtime;version="2.0.0" +Export-Package: org.apache.tuscany.sca.endpoint.tribes;version="2.0.0" diff --git a/sandbox/endpoint-hazelcast/pom.xml b/sandbox/endpoint-hazelcast/pom.xml new file mode 100644 index 0000000000..db2011a387 --- /dev/null +++ b/sandbox/endpoint-hazelcast/pom.xml @@ -0,0 +1,63 @@ + + + + 4.0.0 + + org.apache.tuscany.sca + tuscany-modules + 2.0-SNAPSHOT + ../pom.xml + + tuscany-endpoint-hazelcast + Apache Tuscany SCA EndPoint Registry using Hazelcast + + + + com.hazelcast + hazelcast + 1.8 + + + org.apache.tuscany.sca + tuscany-core-spi + 2.0-SNAPSHOT + compile + + + org.apache.tuscany.sca + tuscany-core + 2.0-SNAPSHOT + test + + + org.apache.tuscany.sca + tuscany-deployment + 2.0-SNAPSHOT + test + + + org.apache.tuscany.sca + tuscany-implementation-java-runtime + 2.0-SNAPSHOT + test + + + + diff --git a/sandbox/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry b/sandbox/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry new file mode 100644 index 0000000000..a16785beef --- /dev/null +++ b/sandbox/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry @@ -0,0 +1,17 @@ +# 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.tribes.ReplicatedEndpointRegistry;ranking=150,address=228.0.0.100,port=50000,timeout=50,scheme=tribes diff --git a/sandbox/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java b/sandbox/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java new file mode 100644 index 0000000000..baf9873efe --- /dev/null +++ b/sandbox/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java @@ -0,0 +1,98 @@ +/* + * 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; + +import java.net.InetAddress; +import java.net.UnknownHostException; +import java.util.List; + +import junit.framework.Assert; + +import org.junit.Test; + +import com.hazelcast.config.Config; +import com.hazelcast.config.TcpIpConfig; +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; + +public class RegistryTestCase { + + @Test + public void foo() throws UnknownHostException { + + HazelcastInstance h1 = create(false, 9001, 9002); + + IMap h1map = h1.getMap("mymap"); + h1map.put("key1", "bla1"); + Assert.assertEquals("bla1", h1map.get("key1")); + + HazelcastInstance h2 = create(false, 9002, 9001, 9003); + IMap h2map = h2.getMap("mymap"); + Assert.assertEquals("bla1", h2map.get("key1")); + + HazelcastInstance h3 = create(false, 9003, 9002); + IMap h3map = h3.getMap("mymap"); + Assert.assertEquals("bla1", h3map.get("key1")); + + HazelcastInstance h4 = create(true, 9004, 9003); + HazelcastInstance h5 = create(true, 9005); + IMap h5map = h5.getMap("mymap"); + Assert.assertEquals("bla1", h5map.get("key1")); + +// HazelcastInstance h6 = create(false, 9006, 9005); +// IMap h6map = h6.getMap("mymap"); +// Assert.assertEquals("bla1", h6map.get("key1")); + + } + + private HazelcastInstance create(boolean multicast, int listenPort, int... connectPorts) throws UnknownHostException { + Config config1 = new XmlConfigBuilder().build(); + + config1.setPort(listenPort); + config1.setPortAutoIncrement(false); + + // declare the interface Hazelcast should bind to + config1.getNetworkConfig().getInterfaces().clear(); + config1.getNetworkConfig().getInterfaces().addInterface(InetAddress.getLocalHost().getHostAddress()); + config1.getNetworkConfig().getInterfaces().setEnabled(true); + + if (!multicast) { + config1.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false); + } + + if (connectPorts.length > 0) { + TcpIpConfig tcpconfig = config1.getNetworkConfig().getJoin().getJoinMembers(); + tcpconfig.setEnabled(true); + + List
lsMembers = tcpconfig.getAddresses(); + lsMembers.clear(); + for (int p : connectPorts) { + lsMembers.add(new Address(InetAddress.getLocalHost(), p)); + } + } + + HazelcastInstance h1 = Hazelcast.newHazelcastInstance(config1); + return h1; + } + +} -- cgit v1.2.3