Another registry impl! this time trying Hazelcast
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@895166 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
antelder
parent
95fa76f5f3
commit
3c55d4251e
4 changed files with 206 additions and 0 deletions
28
sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF
Normal file
28
sandbox/endpoint-hazelcast/META-INF/MANIFEST.MF
Normal file
|
|
@ -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"
|
||||
63
sandbox/endpoint-hazelcast/pom.xml
Normal file
63
sandbox/endpoint-hazelcast/pom.xml
Normal file
|
|
@ -0,0 +1,63 @@
|
|||
<?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</artifactId>
|
||||
<name>Apache Tuscany SCA EndPoint Registry using Hazelcast</name>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>com.hazelcast</groupId>
|
||||
<artifactId>hazelcast</artifactId>
|
||||
<version>1.8</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.tuscany.sca</groupId>
|
||||
<artifactId>tuscany-core-spi</artifactId>
|
||||
<version>2.0-SNAPSHOT</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.tuscany.sca</groupId>
|
||||
<artifactId>tuscany-core</artifactId>
|
||||
<version>2.0-SNAPSHOT</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.tuscany.sca</groupId>
|
||||
<artifactId>tuscany-deployment</artifactId>
|
||||
<version>2.0-SNAPSHOT</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.tuscany.sca</groupId>
|
||||
<artifactId>tuscany-implementation-java-runtime</artifactId>
|
||||
<version>2.0-SNAPSHOT</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
</project>
|
||||
|
|
@ -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
|
||||
|
|
@ -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<Object, Object> h1map = h1.getMap("mymap");
|
||||
h1map.put("key1", "bla1");
|
||||
Assert.assertEquals("bla1", h1map.get("key1"));
|
||||
|
||||
HazelcastInstance h2 = create(false, 9002, 9001, 9003);
|
||||
IMap<Object, Object> h2map = h2.getMap("mymap");
|
||||
Assert.assertEquals("bla1", h2map.get("key1"));
|
||||
|
||||
HazelcastInstance h3 = create(false, 9003, 9002);
|
||||
IMap<Object, Object> h3map = h3.getMap("mymap");
|
||||
Assert.assertEquals("bla1", h3map.get("key1"));
|
||||
|
||||
HazelcastInstance h4 = create(true, 9004, 9003);
|
||||
HazelcastInstance h5 = create(true, 9005);
|
||||
IMap<Object, Object> h5map = h5.getMap("mymap");
|
||||
Assert.assertEquals("bla1", h5map.get("key1"));
|
||||
|
||||
// HazelcastInstance h6 = create(false, 9006, 9005);
|
||||
// IMap<Object, Object> 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<Address> lsMembers = tcpconfig.getAddresses();
|
||||
lsMembers.clear();
|
||||
for (int p : connectPorts) {
|
||||
lsMembers.add(new Address(InetAddress.getLocalHost(), p));
|
||||
}
|
||||
}
|
||||
|
||||
HazelcastInstance h1 = Hazelcast.newHazelcastInstance(config1);
|
||||
return h1;
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in a new issue