diff options
author | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2010-10-18 02:27:38 +0000 |
---|---|---|
committer | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2010-10-18 02:27:38 +0000 |
commit | 1ebc4a56128703c4b746af0b38ff5e63f0cf341a (patch) | |
tree | f26db633b6e265a10d76b358e076c4df8edc45ba /sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast | |
parent | 4f9328953ea16c7a42eb1910f1e809bf1c537d3b (diff) |
Deleting 2.0-M5.1-RC1 release candidate tag
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1023628 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast')
8 files changed, 0 insertions, 996 deletions
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/META-INF/MANIFEST.MF b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/META-INF/MANIFEST.MF deleted file mode 100644 index 9680bb9038..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/META-INF/MANIFEST.MF +++ /dev/null @@ -1,19 +0,0 @@ -Manifest-Version: 1.0
-SCA-Version: 1.1
-Bundle-Name: Apache Tuscany SCA Hazelcast 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 Endpoint Regsitry
-Bundle-SymbolicName: org.apache.tuscany.sca.endpoint.hazelcast
-Bundle-DocURL: http://www.apache.org/
-Bundle-RequiredExecutionEnvironment: J2SE-1.5,JavaSE-1.6 -Import-Package: com.hazelcast.config,
- com.hazelcast.core,
- com.hazelcast.nio,
- org.apache.tuscany.sca.assembly;version="2.0.0",
- org.apache.tuscany.sca.core;version="2.0.0",
- org.apache.tuscany.sca.runtime;version="2.0.0"
-Export-Package: org.apache.tuscany.sca.endpoint.hazelcast;version="2.0.0";
- uses:="org.apache.tuscany.sca.runtime,org.apache.tuscany.sca.assembly,org.apache.tuscany.sca.core"
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/pom.xml b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/pom.xml deleted file mode 100644 index 901c07bae7..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/pom.xml +++ /dev/null @@ -1,63 +0,0 @@ -<?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-M5.1</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.3</version> - </dependency> - <dependency> - <groupId>org.apache.tuscany.sca</groupId> - <artifactId>tuscany-core-spi</artifactId> - <version>2.0-M5.1</version> - <scope>compile</scope> - </dependency> - <dependency> - <groupId>org.apache.tuscany.sca</groupId> - <artifactId>tuscany-core</artifactId> - <version>2.0-M5.1</version> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.apache.tuscany.sca</groupId> - <artifactId>tuscany-deployment</artifactId> - <version>2.0-M5.1</version> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.apache.tuscany.sca</groupId> - <artifactId>tuscany-implementation-java-runtime</artifactId> - <version>2.0-M5.1</version> - <scope>test</scope> - </dependency> - </dependencies> - -</project> diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastDomainRegistryFactory.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastDomainRegistryFactory.java deleted file mode 100644 index 110982a1bd..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastDomainRegistryFactory.java +++ /dev/null @@ -1,49 +0,0 @@ -/* - * 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.util.Properties; - -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.core.UtilityExtensionPoint; -import org.apache.tuscany.sca.runtime.BaseDomainRegistryFactory; -import org.apache.tuscany.sca.runtime.EndpointRegistry; -import org.apache.tuscany.sca.runtime.RuntimeProperties; - -/** - * The utility responsible for finding the endpoint regstry by the scheme and creating instances for the - * given domain - */ -public class HazelcastDomainRegistryFactory extends BaseDomainRegistryFactory { - private final static String[] schemes = new String[] {"multicast", "wka", "tuscany", "hazelcast"}; - - public HazelcastDomainRegistryFactory(ExtensionPointRegistry registry) { - super(registry); - } - - protected EndpointRegistry createEndpointRegistry(String endpointRegistryURI, String domainURI) { - Properties properties = registry.getExtensionPoint(UtilityExtensionPoint.class).getUtility(RuntimeProperties.class).getProperties(); - return new HazelcastEndpointRegistry(registry, properties, domainURI); - } - - public String[] getSupportedSchemes() { - return schemes; - } -} diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java deleted file mode 100644 index 420bcfa3a2..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/HazelcastEndpointRegistry.java +++ /dev/null @@ -1,370 +0,0 @@ -/*
- * 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.io.FileNotFoundException;
-import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.logging.Logger;
-
-import org.apache.tuscany.sca.assembly.AssemblyFactory;
-import org.apache.tuscany.sca.assembly.Endpoint;
-import org.apache.tuscany.sca.core.ExtensionPointRegistry;
-import org.apache.tuscany.sca.core.FactoryExtensionPoint;
-import org.apache.tuscany.sca.core.LifeCycleListener;
-import org.apache.tuscany.sca.core.UtilityExtensionPoint;
-import org.apache.tuscany.sca.runtime.BaseEndpointRegistry;
-import org.apache.tuscany.sca.runtime.EndpointRegistry;
-import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
-import org.apache.tuscany.sca.runtime.RuntimeProperties;
-import org.oasisopen.sca.ServiceRuntimeException;
-
-import com.hazelcast.config.Config;
-import com.hazelcast.config.NearCacheConfig;
-import com.hazelcast.config.TcpIpConfig;
-import com.hazelcast.config.XmlConfigBuilder;
-import com.hazelcast.core.EntryEvent;
-import com.hazelcast.core.EntryListener;
-import com.hazelcast.core.Hazelcast;
-import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.core.ILock;
-import com.hazelcast.core.IMap;
-import com.hazelcast.core.Member;
-import com.hazelcast.core.MembershipEvent;
-import com.hazelcast.core.MembershipListener;
-import com.hazelcast.core.MultiMap;
-import com.hazelcast.core.Transaction;
-import com.hazelcast.nio.Address;
-
-/**
- * An EndpointRegistry using a Hazelcast
- */
-public class HazelcastEndpointRegistry extends BaseEndpointRegistry implements EndpointRegistry, LifeCycleListener, EntryListener<String, Endpoint>, MembershipListener {
- private final static Logger logger = Logger.getLogger(HazelcastEndpointRegistry.class.getName());
-
- private HazelcastInstance hazelcastInstance;
- protected Map<Object, Object> endpointMap;
- protected Map<String, Endpoint> localEndpoints = new ConcurrentHashMap<String, Endpoint>();
- protected MultiMap<String, String> endpointOwners;
- protected AssemblyFactory assemblyFactory;
- protected Object shutdownMutex = new Object();
- protected Properties properties;
-
- public HazelcastEndpointRegistry(ExtensionPointRegistry registry, Properties properties, String domainURI) {
- super(registry, null, null, domainURI);
- this.assemblyFactory = registry.getExtensionPoint(FactoryExtensionPoint.class).getFactory(AssemblyFactory.class);
- this.properties = registry.getExtensionPoint(UtilityExtensionPoint.class).getUtility(RuntimeProperties.class).getProperties();
- }
-
- public HazelcastEndpointRegistry(ExtensionPointRegistry registry,
- Map<String, String> attributes,
- String domainRegistryURI,
- String domainURI) {
- super(registry, attributes, domainRegistryURI, domainURI);
- this.assemblyFactory = registry.getExtensionPoint(FactoryExtensionPoint.class).getFactory(AssemblyFactory.class);
- this.properties = registry.getExtensionPoint(UtilityExtensionPoint.class).getUtility(RuntimeProperties.class).getProperties();
- }
-
- public HazelcastInstance getHazelcastInstance() {
- return hazelcastInstance;
- }
-
- public void start() {
- if (endpointMap != null) {
- throw new IllegalStateException("The registry has already been started");
- }
-// if (configURI.toString().startsWith("tuscany:vm:")) {
-// endpointMap = new HashMap<Object, Object>();
-// } else {
- initHazelcastInstance();
- IMap imap = hazelcastInstance.getMap(domainURI + "/Endpoints");
- imap.addEntryListener(this, true);
- endpointMap = imap;
-
- endpointOwners = hazelcastInstance.getMultiMap(domainURI + "/EndpointOwners");
-
- hazelcastInstance.getCluster().addMembershipListener(this);
-// }
- }
-
- public void stop() {
- if (hazelcastInstance != null) {
- synchronized (shutdownMutex) {
- hazelcastInstance.shutdown();
- hazelcastInstance = null;
- endpointMap = null;
- endpointOwners = null;
- }
- }
- }
-
- private void initHazelcastInstance() {
- Config config = getHazelcastConfig();
-
- // do this when theres a way to have adders be the key owners
- // config.getMapConfig(configURI.getDomainName() + "/Endpoints").setBackupCount(0);
-
- // this caches reads locally
- config.getMapConfig("default").setNearCacheConfig(new NearCacheConfig(0, 0, "NONE", 0, true));
-
- // Disable the Hazelcast shutdown hook as Tuscany has its own and with both there are race conditions
- config.setProperty("hazelcast.shutdownhook.enabled",
- // GroupProperties.PROP_SHUTDOWNHOOK_ENABLED,
- "false");
-
- // By default this is 5 seconds, not sure what the implications are but dropping it down to 1 makes
- // things like the samples look much faster
- config.setProperty("hazelcast.wait.seconds.before.join",
- // GroupProperties.PROP_WAIT_SECONDS_BEFORE_JOIN,
- "1");
-
- this.hazelcastInstance = Hazelcast.newHazelcastInstance(config);
- }
-
- protected Config getHazelcastConfig() {
- Config config;
- this.properties = registry.getExtensionPoint(UtilityExtensionPoint.class).getUtility(RuntimeProperties.class).getProperties();
- String configFile = properties.getProperty("hazelcastConfig");
- if (configFile != null) {
- try {
- config = new XmlConfigBuilder(configFile).build();
- } catch (FileNotFoundException e) {
- throw new IllegalArgumentException(configFile, e);
- }
- } else {
- config = new XmlConfigBuilder().build();
- RegistryConfig rc = new RegistryConfig(properties);
- config.setPort(rc.getBindPort());
- //config.setPortAutoIncrement(false);
-
- if (!rc.getBindAddress().equals("*")) {
- config.getNetworkConfig().getInterfaces().setEnabled(true);
- config.getNetworkConfig().getInterfaces().clear();
- config.getNetworkConfig().getInterfaces().addInterface(rc.getBindAddress());
- }
-
- config.getGroupConfig().setName(rc.getUserid());
- config.getGroupConfig().setPassword(rc.getPassword());
-
- if (rc.isMulticastDisabled()) {
- config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false);
- } else {
- config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(true);
- config.getNetworkConfig().getJoin().getMulticastConfig().setMulticastPort(rc.getMulticastPort());
- config.getNetworkConfig().getJoin().getMulticastConfig().setMulticastGroup(rc.getMulticastAddress());
- }
-
- if (rc.getWKAs().size() > 0) {
- TcpIpConfig tcpconfig = config.getNetworkConfig().getJoin().getTcpIpConfig();
- tcpconfig.setEnabled(true);
- List<Address> lsMembers = tcpconfig.getAddresses();
- lsMembers.clear();
- for (String addr : rc.getWKAs()) {
- String[] ipNPort = addr.split(":");
- try {
- lsMembers.add(new Address(ipNPort[0], Integer.parseInt(ipNPort[1])));
- } catch (UnknownHostException e) {
- throw new RuntimeException(e);
- }
- }
- }
- }
- return config;
- }
-
- public void addEndpoint(Endpoint endpoint) {
- if (findEndpoint(endpoint.getURI()).size() > 0) {
- Member m = getOwningMember(endpoint.getURI());
- throw new IllegalStateException("Endpoint " + endpoint.getURI() + " already exists in domain " + domainURI + " at " + m.getInetSocketAddress());
- }
-
- String localMemberAddr = hazelcastInstance.getCluster().getLocalMember().getInetSocketAddress().toString();
- String endpointURI = endpoint.getURI();
- Transaction txn = hazelcastInstance.getTransaction();
- txn.begin();
- try {
- endpointMap.put(endpointURI, endpoint);
- endpointOwners.put(localMemberAddr, endpointURI);
- txn.commit();
- } catch (Throwable e) {
- txn.rollback();
- throw new ServiceRuntimeException(e);
- }
- localEndpoints.put(endpointURI, endpoint);
- logger.info("Add endpoint - " + endpoint);
- }
-
- public List<Endpoint> findEndpoint(String uri) {
- List<Endpoint> foundEndpoints = new ArrayList<Endpoint>();
- for (Object v : endpointMap.values()) {
- Endpoint endpoint = (Endpoint)v;
- logger.fine("Matching against - " + endpoint);
- if (endpoint.matches(uri)) {
- if (!isLocal(endpoint)) {
- endpoint.setRemote(true);
- ((RuntimeEndpoint)endpoint).bind(registry, this);
- } else {
- // get the local version of the endpoint
- // this local version won't have been serialized
- // won't be marked as remote and will have the
- // full interface contract information
- endpoint = localEndpoints.get(endpoint.getURI());
- }
-
- foundEndpoints.add(endpoint);
- logger.fine("Found endpoint with matching service - " + endpoint);
- }
- }
- return foundEndpoints;
- }
-
-
- private boolean isLocal(Endpoint endpoint) {
- return localEndpoints.containsKey(endpoint.getURI());
- }
-
- public Endpoint getEndpoint(String uri) {
- return (Endpoint)endpointMap.get(uri);
- }
-
- public List<Endpoint> getEndpoints() {
- return new ArrayList(endpointMap.values());
- }
-
- public void removeEndpoint(Endpoint endpoint) {
- if (hazelcastInstance == null) {
- return;
- }
- synchronized (shutdownMutex) {
- String localMemberAddr = hazelcastInstance.getCluster().getLocalMember().getInetSocketAddress().toString();
- String endpointURI = endpoint.getURI();
-
-// TODO: seems to be a txn bug in Hazelcast, see http://code.google.com/p/hazelcast/issues/detail?id=258
-// Transaction txn = hazelcastInstance.getTransaction();
-// txn.begin();
-// try {
- endpointOwners.remove(localMemberAddr, endpointURI);
- endpointMap.remove(endpointURI);
-// txn.commit();
-// } catch (Throwable e) {
-// txn.rollback();
-// throw new ServiceRuntimeException(e);
-// }
- localEndpoints.remove(endpointURI);
- logger.info("Removed endpoint - " + endpoint);
- }
- }
-
-
- public void entryAdded(EntryEvent<String, Endpoint> event) {
- entryAdded(event.getKey(), event.getValue());
- }
-
- public void entryEvicted(EntryEvent<String, Endpoint> event) {
- // Should not happen
- }
-
- public void entryRemoved(EntryEvent<String, Endpoint> event) {
- entryRemoved(event.getKey(), event.getValue());
- }
-
- public void entryUpdated(EntryEvent<String, Endpoint> event) {
- entryUpdated(event.getKey(), null, event.getValue());
- }
-
- public void entryAdded(Object key, Object value) {
- Endpoint newEp = (Endpoint)value;
- if (!isLocal(newEp)) {
- logger.info(" Remote endpoint added: " + newEp);
- }
- endpointAdded(newEp);
- }
-
- public void entryRemoved(Object key, Object value) {
- Endpoint oldEp = (Endpoint)value;
- if (!isLocal(oldEp)) {
- logger.info(" Remote endpoint removed: " + value);
- }
- endpointRemoved(oldEp);
- }
-
- public void entryUpdated(Object key, Object oldValue, Object newValue) {
- Endpoint oldEp = (Endpoint)oldValue;
- Endpoint newEp = (Endpoint)newValue;
- if (!isLocal(newEp)) {
- logger.info(" Remote endpoint updated: " + newEp);
- }
- endpointUpdated(oldEp, newEp);
- }
-
- public void memberAdded(MembershipEvent event) {
- }
-
- public void memberRemoved(MembershipEvent event) {
- try {
- String memberAddr = event.getMember().getInetSocketAddress().toString();
- if (endpointOwners.containsKey(memberAddr)) {
- synchronized (shutdownMutex) {
- ILock lock = hazelcastInstance.getLock("EndpointOwners/" + memberAddr);
- lock.lock();
- try {
- if (endpointOwners.containsKey(memberAddr)) {
- Collection<String> keys = endpointOwners.remove(memberAddr);
- for (Object k : keys) {
- endpointMap.remove(k);
- }
- }
- } finally {
- lock.unlock();
- }
- }
- }
- } catch (Exception e) {
- if (e.getCause() != null && e.getCause().getCause() != null) {
- // ignore hazelcast already shutdown exception
- if (!"Hazelcast Instance is not active!".equals(e.getCause().getCause().getMessage())) {
- throw new ServiceRuntimeException(e);
- }
- }
- }
- }
-
- public Member getOwningMember(String serviceURI) {
- for (String memberAddr : endpointOwners.keySet()) {
- for (String service : endpointOwners.get(memberAddr)) {
- Endpoint ep = assemblyFactory.createEndpoint();
- ep.setURI(service);
- if (ep.matches(serviceURI)) {
- for (Member m : getHazelcastInstance().getCluster().getMembers()) {
- if (memberAddr.equals(m.getInetSocketAddress().toString())) {
- return m;
- }
- }
- }
- }
- }
- return null;
- }
-}
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryConfig.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryConfig.java deleted file mode 100644 index c6b1ccaa21..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryConfig.java +++ /dev/null @@ -1,179 +0,0 @@ -/*
- * 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.NetworkInterface;
-import java.util.ArrayList;
-import java.util.Enumeration;
-import java.util.List;
-import java.util.Properties;
-
-
-/**
- * Utility to parse the config properties.
- *
- * bind - ip[:port] - defines the local bind address and port, it defaults to the network interface with the widest
- * class (ie class A is wider than class B) on port 14820 and if that port in use it will try
- * incrementing by one till a free port is found.
- *
- * multicast - groupip:port | off - defines if multicast discovery is used and if so what multicast ip group and port is used
- * defaults to 224.5.12.10:51482. A value of off means multicast is disabled.
- *
- * wka - ip[:port] - a comma separated list of ip address and port for remote nodes in the domain group. The port defaults to 14820.
- *
- * userid - is the userid other nodes must use to connect to this domain group. The default is the default domain name.
- *
- * password - is the password other nodes must use to connect to this domain group. The default is 'tuscany'.
- *
- * client - true means this is an SCAClient call
- *
- */
-public class RegistryConfig {
-
- private String bindAddress = "*";
- private int bindPort = 14820;
- private boolean multicastDisabled = false;
- private String multicastAddress = "224.5.12.10";
- private int multicastPort = 51482;
- private List<String> wkas = new ArrayList<String>();
- private String userid;
- private String password;
- boolean client;
-
- public RegistryConfig(Properties properties) {
- init(properties);
- }
-
- private void init(Properties properties) {
-
- String bindValue = properties.getProperty("bind");
- if (bindValue == null) {
- InetAddress addr = chooseLocalAddress();
- if (addr != null) {
- this.bindAddress = addr.getHostAddress();
- }
- } else {
- if (bindValue.indexOf(":") == -1) {
- this.bindAddress = bindValue;
- } else {
- String[] addr = bindValue.split(":");
- this.bindAddress = addr[0];
- this.bindPort = Integer.parseInt(addr[1]);
- }
- }
-
- String multicastValue = properties.getProperty("multicast");
- if (multicastValue != null) {
- if ("off".equalsIgnoreCase(multicastValue)) {
- this.multicastDisabled = true;
- } else {
- if (multicastValue.indexOf(":") == -1) {
- this.multicastAddress = multicastValue;
- } else {
- String[] addr = multicastValue.split(":");
- this.multicastAddress = addr[0];
- this.multicastPort = Integer.parseInt(addr[1]);
- }
- }
- }
-
- String wkaValue = properties.getProperty("wka");
- if (wkaValue != null) {
- String[] ips = wkaValue.split(",");
- for (String ip : ips) {
- if (ip.indexOf(":") == -1) {
- wkas.add(ip + ":14820");
- } else {
- wkas.add(ip);
- }
- }
- }
-
- this.client = Boolean.parseBoolean(properties.getProperty("client", "false"));
- this.password = properties.getProperty("password", "tuscany");
- this.userid = properties.getProperty("userid", properties.getProperty("defaultDomainName", "default"));
-
- }
-
- public String getBindAddress() {
- return bindAddress;
- }
-
- public int getBindPort() {
- return bindPort;
- }
-
- public boolean isMulticastDisabled() {
- return multicastDisabled;
- }
-
- public String getMulticastAddress() {
- return multicastAddress;
- }
-
- public int getMulticastPort() {
- return multicastPort;
- }
-
- public List<String> getWKAs() {
- return wkas;
- }
-
- public String getUserid() {
- return userid;
- }
- public String getPassword() {
- return password;
- }
-
- /**
- * Use the NIC address with the widest class, ie class A instead of class B or C.
- * Bit crude but in a lot of environments a class A address (eg 10.x.x.x) is likely
- * a better choice than a class C address (eg 192.x.x.x). And the alternative to
- * this is to just choose the first address of the first network interface which
- * likely isn't a better choice than this approach.
- */
- protected InetAddress chooseLocalAddress() {
- InetAddress chosen = null;
- try {
- Enumeration<NetworkInterface> nis = NetworkInterface.getNetworkInterfaces();
- while (nis.hasMoreElements()) {
- NetworkInterface ni = nis.nextElement();
- Enumeration<InetAddress> ips = ni.getInetAddresses();
- while (ips.hasMoreElements()) {
- InetAddress addr = ips.nextElement();
- if (!addr.isLoopbackAddress()) {
- if (chosen == null) {
- chosen = addr;
- } else {
- if (((int) addr.getAddress()[0] & 0xFF) < ((int) chosen.getAddress()[0] & 0xFF)) {
- chosen = addr;
- }
- }
- }
- }
- }
- } catch (Exception e) {
- // ignore
- }
- return chosen;
- }
-}
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.DomainRegistryFactory b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.DomainRegistryFactory deleted file mode 100644 index 23551701a5..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.DomainRegistryFactory +++ /dev/null @@ -1,17 +0,0 @@ -# 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.HazelcastDomainRegistryFactory;ranking=100
diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/MultiRegTestCase.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/MultiRegTestCase.java deleted file mode 100644 index c4391e59bb..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/MultiRegTestCase.java +++ /dev/null @@ -1,157 +0,0 @@ -/* - * 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 org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.assembly.Binding; -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.SCABindingFactory; -import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; -import org.apache.tuscany.sca.runtime.RuntimeEndpoint; -import org.junit.Assert; -import org.junit.BeforeClass; -import org.junit.Test; - -public class MultiRegTestCase { - private static ExtensionPointRegistry extensionPoints; - private static AssemblyFactory assemblyFactory; - private static SCABindingFactory scaBindingFactory; - - @BeforeClass - public static void init() { - extensionPoints = new DefaultExtensionPointRegistry(); - FactoryExtensionPoint factories = extensionPoints.getExtensionPoint(FactoryExtensionPoint.class); - assemblyFactory = factories.getFactory(AssemblyFactory.class); - scaBindingFactory = factories.getFactory(SCABindingFactory.class); - } - - @Test - public void testReplication() throws Exception { - - System.out.println("Starting reg1"); - HazelcastEndpointRegistry reg1 = new HazelcastEndpointRegistry(extensionPoints, null, "tuscany:foo?listen=127.0.0.1:9876&multicast=off", "bar"); - reg1.start(); - - System.out.println("Adding ep1"); - RuntimeEndpoint ep1 = createEndpoint("ep1uri"); - ep1.bind(extensionPoints, reg1); - reg1.addEndpoint(ep1); - - System.out.println("Starting reg3"); - HazelcastEndpointRegistry reg2 = new HazelcastEndpointRegistry(extensionPoints, null, "tuscany:foo?listen=127.0.0.1:9877&multicast=off&remotes=127.0.0.1:9876", "bar"); - reg2.start(); - - System.out.println("Starting reg2"); - HazelcastEndpointRegistry reg3 = new HazelcastEndpointRegistry(extensionPoints, null, "tuscany:foo?listen=127.0.0.1:9878&multicast=off&remotes=127.0.0.1:9877", "bar"); - reg3.start(); - - assertExists(reg1, "ep1uri"); - assertExists(reg2, "ep1uri"); - assertExists(reg3, "ep1uri"); - - System.out.println("Adding ep2"); - RuntimeEndpoint ep2 = createEndpoint("ep2uri"); - ep2.bind(extensionPoints, reg2); - reg2.addEndpoint(ep2); - - assertExists(reg2, "ep2uri"); - assertExists(reg1, "ep2uri"); - assertExists(reg3, "ep2uri"); - - System.out.println("Stopping reg1"); - reg1.stop(); - System.out.println("Stopped reg1"); - Thread.sleep(500); - - Assert.assertNull(reg2.getEndpoint("ep1uri")); - Assert.assertNull(reg3.getEndpoint("ep1uri")); - - assertExists(reg2, "ep2uri"); - assertExists(reg3, "ep2uri"); - - System.out.println("Starting reg1"); - reg1.start(); - ep1.bind(extensionPoints, reg1); - - System.out.println("adding ep1"); - reg1.addEndpoint(ep1); - assertExists(reg1, "ep1uri"); - assertExists(reg2, "ep1uri"); - assertExists(reg3, "ep1uri"); - - System.out.println("Stopping reg1"); - reg1.stop(); - System.out.println("Stopping reg2"); - reg2.stop(); - System.out.println("Stopping reg3"); - reg3.stop(); - System.out.println("done"); - } - - @Test - public void testDuplicates() throws Exception { - HazelcastEndpointRegistry reg1 = new HazelcastEndpointRegistry(extensionPoints, null, "tuscany:foo?listen=127.0.0.1:9876&multicast=off", "bar"); - reg1.start(); - RuntimeEndpoint ep1 = createEndpoint("ep1uri"); - ep1.bind(extensionPoints, reg1); - reg1.addEndpoint(ep1); - - HazelcastEndpointRegistry reg2 = new HazelcastEndpointRegistry(extensionPoints, null, "tuscany:foo?listen=127.0.0.1:9877&multicast=off&remotes=127.0.0.1:9876", "bar"); - reg2.start(); - - try { - reg2.addEndpoint(ep1); - Assert.fail(); - } catch (IllegalStateException e) { - // expected - } - - reg1.stop(); - - Thread.sleep(200); - - // now it should work - reg2.addEndpoint(ep1); - - reg2.stop(); - } - - private Endpoint assertExists(HazelcastEndpointRegistry reg, String uri) throws InterruptedException { - Endpoint ep = reg.getEndpoint(uri); - Assert.assertNotNull(ep); - Assert.assertEquals(uri, ep.getURI()); - return ep; - } - - private RuntimeEndpoint createEndpoint(String uri) { - RuntimeEndpoint ep = (RuntimeEndpoint) assemblyFactory.createEndpoint(); - Component comp = assemblyFactory.createComponent(); - ep.setComponent(comp); - ep.setService(assemblyFactory.createComponentService()); - Binding b = scaBindingFactory.createSCABinding(); - ep.setBinding(b); - ep.setURI(uri); - return ep; - } - -} diff --git a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java b/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java deleted file mode 100644 index edfe186667..0000000000 --- a/sca-java-2.x/tags/2.0-M5.1-RC1/modules/endpoint-hazelcast/src/test/java/org/apache/tuscany/sca/endpoint/hazelcast/RegistryTestCase.java +++ /dev/null @@ -1,142 +0,0 @@ -/*
- * 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.Ignore;
-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;
-
-@Ignore
-public class RegistryTestCase {
-
- @Test
- public void test1() throws UnknownHostException {
-
- HazelcastInstance h1 = create("54327", 9001);
-
- IMap<Object, Object> h1map = h1.getMap("mymap");
- h1map.put("key1", "bla1");
- Assert.assertEquals("bla1", h1map.get("key1"));
-
- HazelcastInstance h2 = create("false", 9002, 9001);
- 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"));
-
- h3map.put("k3", "v3");
- h2map.put("k2", "v2");
-
- Assert.assertEquals("v2", h1map.get("k2"));
- Assert.assertEquals("v3", h1map.get("k3"));
- Assert.assertEquals("v2", h2map.get("k2"));
- Assert.assertEquals("v3", h2map.get("k3"));
- Assert.assertEquals("v2", h3map.get("k2"));
- Assert.assertEquals("v3", h3map.get("k3"));
-
- HazelcastInstance h4 = create("54328", 9004, 9001);
- IMap<Object, Object> h4map = h4.getMap("mymap");
-// Assert.assertNull(h4map.get("k2"));
-// Assert.assertNull(h4map.get("k3"));
- Assert.assertEquals("v2", h4map.get("k2"));
- Assert.assertEquals("v3", h4map.get("k3"));
-
-// HazelcastInstance h5 = create("false", 9005, 9003, 9004);
- HazelcastInstance h5 = create("54328", 9005);
-
-// Assert.assertEquals("v2", h4map.get("k2"));
-// Assert.assertEquals("v3", h4map.get("k3"));
-
- IMap<Object, Object> h5map = h5.getMap("mymap");
- Assert.assertEquals("v2", h5map.get("k2"));
- Assert.assertEquals("v3", h5map.get("k3"));
-
- h1.shutdown();
-
- Assert.assertEquals("v2", h2map.get("k2"));
- Assert.assertEquals("v3", h2map.get("k3"));
- Assert.assertEquals("v2", h3map.get("k2"));
- Assert.assertEquals("v3", h3map.get("k3"));
- Assert.assertEquals("v2", h4map.get("k2"));
- Assert.assertEquals("v3", h4map.get("k3"));
-
- h3map.put("key1a", "bla1a");
-
- Assert.assertEquals("bla1a", h2map.get("key1a"));
- Assert.assertEquals("bla1a", h3map.get("key1a"));
- Assert.assertEquals("bla1a", h4map.get("key1a"));
-
-// 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(String multicast, int listenPort, int... connectPorts) throws UnknownHostException {
- Config config = new XmlConfigBuilder().build();
- config.setPort(listenPort);
- config.setPortAutoIncrement(false);
-
- // declare the interface Hazelcast should bind to
- config.getNetworkConfig().getInterfaces().clear();
- config.getNetworkConfig().getInterfaces().addInterface(InetAddress.getLocalHost().getHostAddress());
- config.getNetworkConfig().getInterfaces().setEnabled(true);
-
- if ("false".equals(multicast)) {
- config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false);
- } else {
- config.getNetworkConfig().getJoin().getMulticastConfig().setMulticastPort(Integer.parseInt(multicast));
- }
-
- if (connectPorts.length > 0) {
- TcpIpConfig tcpconfig = config.getNetworkConfig().getJoin().getTcpIpConfig();
- tcpconfig.setEnabled(true);
-
- List<Address> lsMembers = tcpconfig.getAddresses();
- lsMembers.clear();
- for (int p : connectPorts) {
- lsMembers.add(new Address(InetAddress.getLocalHost(), p));
- }
- }
-
- return Hazelcast.newHazelcastInstance(config);
- }
-
-}
|