Fix svn:eol-style and svn:keywords properties for java/xml files

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

2 files changed, 450 insertions, 450 deletions

diff --git a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/MapStore.java b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/MapStore.java
index d667f10c50..9e540743bf 100644
--- a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/MapStore.java
+++ b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/MapStore.java
@@ -1,83 +1,83 @@
-/*

- * 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.tribes;

-

-import java.util.List;

-import java.util.concurrent.ConcurrentHashMap;

-import java.util.concurrent.CopyOnWriteArrayList;

-

-/**

- * The Map that can fire events on put/remove of entries

- */

-public abstract class MapStore extends ConcurrentHashMap<Object, Object> {

-    private static final long serialVersionUID = -2127235547082144368L;

-    private List<MapListener> listeners = new CopyOnWriteArrayList<MapListener>();

-

-    protected MapStore(int initialCapacity, float loadFactor, int concurrencyLevel) {

-        super(initialCapacity, loadFactor, concurrencyLevel);

-    }

-

-    @Override

-    public Object put(Object key, Object value) {

-        Object old = super.put(key, value);

-        if (old != null) {

-            for (MapListener listener : listeners) {

-                listener.entryUpdated(key, old, value);

-            }

-        } else {

-            for (MapListener listener : listeners) {

-                listener.entryAdded(key, value);

-            }

-

-        }

-        return old;

-    }

-

-    @Override

-    public Object remove(Object key) {

-        Object old = super.remove(key);

-        if (old != null) {

-            for (MapListener listener : listeners) {

-                listener.entryRemoved(key, old);

-            }

-        }

-        return old;

-    }

-

-    public void addListener(MapListener listener) {

-        listeners.add(listener);

-    }

-

-    public List<MapListener> getListeners() {

-        return listeners;

-    }

-

-    public boolean removeListener(MapListener listener) {

-        return listeners.remove(listener);

-    }

-

-    public static interface MapListener {

-        void entryAdded(Object key, Object value);

-

-        void entryUpdated(Object key, Object oldValue, Object newValue);

-

-        void entryRemoved(Object key, Object value);

-    }

-}

+/*
+ * 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.tribes;
+
+import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+/**
+ * The Map that can fire events on put/remove of entries
+ */
+public abstract class MapStore extends ConcurrentHashMap<Object, Object> {
+    private static final long serialVersionUID = -2127235547082144368L;
+    private List<MapListener> listeners = new CopyOnWriteArrayList<MapListener>();
+
+    protected MapStore(int initialCapacity, float loadFactor, int concurrencyLevel) {
+        super(initialCapacity, loadFactor, concurrencyLevel);
+    }
+
+    @Override
+    public Object put(Object key, Object value) {
+        Object old = super.put(key, value);
+        if (old != null) {
+            for (MapListener listener : listeners) {
+                listener.entryUpdated(key, old, value);
+            }
+        } else {
+            for (MapListener listener : listeners) {
+                listener.entryAdded(key, value);
+            }
+
+        }
+        return old;
+    }
+
+    @Override
+    public Object remove(Object key) {
+        Object old = super.remove(key);
+        if (old != null) {
+            for (MapListener listener : listeners) {
+                listener.entryRemoved(key, old);
+            }
+        }
+        return old;
+    }
+
+    public void addListener(MapListener listener) {
+        listeners.add(listener);
+    }
+
+    public List<MapListener> getListeners() {
+        return listeners;
+    }
+
+    public boolean removeListener(MapListener listener) {
+        return listeners.remove(listener);
+    }
+
+    public static interface MapListener {
+        void entryAdded(Object key, Object value);
+
+        void entryUpdated(Object key, Object oldValue, Object newValue);
+
+        void entryRemoved(Object key, Object value);
+    }
+}
diff --git a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
index 61daa958e0..5348341b4e 100644
--- a/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
+++ b/java/sca/modules/endpoint-tribes/src/main/java/org/apache/tuscany/sca/endpoint/tribes/ReplicatedEndpointRegistry.java
@@ -1,367 +1,367 @@
-/*

- * 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.tribes;

-

-import java.net.InetAddress;

-import java.net.NetworkInterface;

-import java.util.ArrayList;

-import java.util.Enumeration;

-import java.util.List;

-import java.util.Map;

-import java.util.UUID;

-import java.util.concurrent.CopyOnWriteArrayList;

-import java.util.logging.Level;

-import java.util.logging.Logger;

-

-import org.apache.catalina.tribes.Channel;

-import org.apache.catalina.tribes.ChannelException;

-import org.apache.catalina.tribes.group.GroupChannel;

-import org.apache.catalina.tribes.membership.McastService;

-import org.apache.tuscany.sca.assembly.Endpoint;

-import org.apache.tuscany.sca.assembly.EndpointReference;

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

-import org.apache.tuscany.sca.core.LifeCycleListener;

-import org.apache.tuscany.sca.endpoint.tribes.AbstractReplicatedMap.MapEntry;

-import org.apache.tuscany.sca.endpoint.tribes.MapStore.MapListener;

-import org.apache.tuscany.sca.runtime.EndpointListener;

-import org.apache.tuscany.sca.runtime.EndpointRegistry;

-

-/**

- * A replicated EndpointRegistry based on Apache Tomcat Tribes

- */

-public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleListener, MapListener {

-    private final static Logger logger = Logger.getLogger(ReplicatedEndpointRegistry.class.getName());

-    private static final String MULTICAST_ADDRESS = "228.0.0.100";

-    private static final int MULTICAST_PORT = 50000;

-

-    private int port = MULTICAST_PORT;

-    private String address = MULTICAST_ADDRESS;

-    private String bind = null;

-    private int timeout = 50;

-

-    private final static String DEFAULT_DOMAIN_URI = "http://tuscany.apache.org/sca/1.1/domains/default";

-    private String domainURI = DEFAULT_DOMAIN_URI;

-    private List<EndpointReference> endpointreferences = new CopyOnWriteArrayList<EndpointReference>();

-    private List<EndpointListener> listeners = new CopyOnWriteArrayList<EndpointListener>();

-

-    private ExtensionPointRegistry registry;

-    private ReplicatedMap map;

-

-    private static final Channel createChannel(String address, int port, String bindAddress) {

-

-        //create a channel

-        GroupChannel channel = new GroupChannel();

-        McastService mcastService = (McastService)channel.getMembershipService();

-        mcastService.setPort(port);

-        mcastService.setAddress(address);

-

-        // REVIEW: In my case, there are multiple IP addresses

-        // One for the WIFI and the other one for VPN. For some reason the VPN one doesn't support

-        // Multicast

-

-        if (bindAddress != null) {

-            mcastService.setBind(bindAddress);

-        } else {

-            mcastService.setBind(getBindAddress());

-        }

-

-        return channel;

-    }

-

-    public ReplicatedEndpointRegistry(ExtensionPointRegistry registry, Map<String, String> attributes) {

-        this.registry = registry;

-        String portStr = attributes.get("port");

-        if (portStr != null) {

-            port = Integer.parseInt(portStr);

-        }

-        String address = attributes.get("address");

-        if (address == null) {

-            address = MULTICAST_ADDRESS;

-        }

-        bind = attributes.get("bind");

-        String timeoutStr = attributes.get("timeout");

-        if (timeoutStr != null) {

-            timeout = Integer.parseInt(timeoutStr);

-        }

-        // start();

-    }

-

-    public ReplicatedEndpointRegistry(String domainURI) {

-        this.domainURI = domainURI;

-        // start();

-    }

-

-    public void start() {

-        if (map != null) {

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

-        }

-        map =

-            new ReplicatedMap(null, createChannel(address, port, bind), timeout, this.domainURI,

-                              new ClassLoader[] {ReplicatedEndpointRegistry.class.getClassLoader()});

-        map.addListener(this);

-        try {

-            map.getChannel().start(Channel.DEFAULT);

-        } catch (ChannelException e) {

-            throw new IllegalStateException(e);

-        }

-    }

-

-    public void stop() {

-        if (map != null) {

-            map.removeListener(this);

-            Channel channel = map.getChannel();

-            map.breakdown();

-            try {

-                channel.stop(Channel.DEFAULT);

-            } catch (ChannelException e) {

-                throw new IllegalStateException(e);

-            }

-            map = null;

-        }

-    }

-

-    public void addEndpoint(Endpoint endpoint) {

-        map.put(endpoint.getURI(), endpoint);

-        logger.info("Add endpoint - " + endpoint);

-    }

-

-    public void addEndpointReference(EndpointReference endpointReference) {

-        endpointreferences.add(endpointReference);

-        logger.info("Add endpoint reference - " + endpointReference);

-    }

-

-    public void addListener(EndpointListener listener) {

-        listeners.add(listener);

-    }

-

-    /**

-     * Parse the component/service/binding URI into an array of parts (componentURI, serviceName, bindingName)

-     * @param uri

-     * @return

-     */

-    private String[] parse(String uri) {

-        String[] names = new String[3];

-        int index = uri.lastIndexOf('#');

-        if (index == -1) {

-            names[0] = uri;

-        } else {

-            names[0] = uri.substring(0, index);

-            String str = uri.substring(index + 1);

-            if (str.startsWith("service-binding(") && str.endsWith(")")) {

-                str = str.substring("service-binding(".length(), str.length() - 1);

-                String[] parts = str.split("/");

-                if (parts.length != 2) {

-                    throw new IllegalArgumentException("Invalid service-binding URI: " + uri);

-                }

-                names[1] = parts[0];

-                names[2] = parts[1];

-            } else if (str.startsWith("service(") && str.endsWith(")")) {

-                str = str.substring("service(".length(), str.length() - 1);

-                names[1] = str;

-            } else {

-                throw new IllegalArgumentException("Invalid component/service/binding URI: " + uri);

-            }

-        }

-        return names;

-    }

-

-    private boolean matches(String target, String uri) {

-        String[] parts1 = parse(target);

-        String[] parts2 = parse(uri);

-        for (int i = 0; i < parts1.length; i++) {

-            if (parts1[i] == null || parts1[i].equals(parts2[i])) {

-                continue;

-            } else {

-                return false;

-            }

-        }

-        return true;

-    }

-

-    public List<Endpoint> findEndpoint(EndpointReference endpointReference) {

-        List<Endpoint> foundEndpoints = new ArrayList<Endpoint>();

-

-        logger.info("Find endpoint for reference - " + endpointReference);

-

-        if (endpointReference.getReference() != null) {

-            Endpoint targetEndpoint = endpointReference.getTargetEndpoint();

-            for (Object v : map.values()) {

-                Endpoint endpoint = (Endpoint)v;

-                // TODO: implement more complete matching

-                if (matches(targetEndpoint.getURI(), endpoint.getURI())) {

-                    MapEntry entry = map.getInternal(endpoint.getURI());

-                    if (!isLocal(entry)) {

-                        endpoint.setRemote(true);

-                    }

-                    // if (!entry.isPrimary()) {

-                    endpoint.setExtensionPointRegistry(registry);

-                    // }

-                    foundEndpoints.add(endpoint);

-                    logger.info("Found endpoint with matching service  - " + endpoint);

-                }

-                // else the service name doesn't match

-            }

-        }

-        return foundEndpoints;

-    }

-

-    private boolean isLocal(MapEntry entry) {

-        return entry.getPrimary().equals(map.getChannel().getLocalMember(false));

-    }

-

-    public List<EndpointReference> findEndpointReference(Endpoint endpoint) {

-        return endpointreferences;

-    }

-

-    public Endpoint getEndpoint(String uri) {

-        return (Endpoint)map.get(uri);

-    }

-

-    public List<EndpointReference> getEndpointRefereneces() {

-        return endpointreferences;

-    }

-

-    public List<Endpoint> getEndpoints() {

-        return new ArrayList(map.values());

-    }

-

-    public List<EndpointListener> getListeners() {

-        return listeners;

-    }

-

-    public void removeEndpoint(Endpoint endpoint) {

-        map.remove(endpoint.getURI());

-        logger.info("Remove endpoint - " + endpoint);

-    }

-

-    public void removeEndpointReference(EndpointReference endpointReference) {

-        endpointreferences.remove(endpointReference);

-        logger.info("Remove endpoint reference - " + endpointReference);

-    }

-

-    public void removeListener(EndpointListener listener) {

-        listeners.remove(listener);

-    }

-

-    public void updateEndpoint(String uri, Endpoint endpoint) {

-        Endpoint oldEndpoint = getEndpoint(uri);

-        if (oldEndpoint == null) {

-            throw new IllegalArgumentException("Endpoint is not found: " + uri);

-        }

-        map.put(endpoint.getURI(), endpoint);

-    }

-

-    public void entryAdded(Object key, Object value) {

-        MapEntry entry = (MapEntry)value;

-        if (!isLocal(entry)) {

-            logger.info("Remote endpoint added: " + entry.getValue());

-        }

-        Endpoint newEp = (Endpoint)entry.getValue();

-        for (EndpointListener listener : listeners) {

-            listener.endpointAdded(newEp);

-        }

-    }

-

-    public void entryRemoved(Object key, Object value) {

-        MapEntry entry = (MapEntry)value;

-        if (!isLocal(entry)) {

-            logger.info("Remote endpoint removed: " + entry.getValue());

-        }

-        Endpoint oldEp = (Endpoint)entry.getValue();

-        for (EndpointListener listener : listeners) {

-            listener.endpointRemoved(oldEp);

-        }

-    }

-

-    public void entryUpdated(Object key, Object oldValue, Object newValue) {

-        MapEntry oldEntry = (MapEntry)oldValue;

-        MapEntry newEntry = (MapEntry)newValue;

-        if (!isLocal(newEntry)) {

-            logger.info("Remote endpoint updated: " + newEntry.getValue());

-        }

-        Endpoint oldEp = (Endpoint)oldEntry.getValue();

-        Endpoint newEp = (Endpoint)newEntry.getValue();

-        for (EndpointListener listener : listeners) {

-            listener.endpointUpdated(oldEp, newEp);

-        }

-    }

-

-    public static void main(String[] args) throws Exception {

-        //create a channel

-        GroupChannel channel = new GroupChannel();

-        McastService mcastService = (McastService)channel.getMembershipService();

-        mcastService.setPort(MULTICAST_PORT);

-        mcastService.setAddress(MULTICAST_ADDRESS);

-

-        InetAddress localhost = InetAddress.getLocalHost();

-

-        // REVIEW: In my case, there are multiple IP addresses

-        // One for the WIFI and the other one for VPN. For some reason the VPN one doesn't support

-        // Multicast

-

-        // You can use "route add 228.0.0.0 mask 252.0.0.0 192.168.1.100"

-        mcastService.setBind(getBindAddress());

-        channel.start(Channel.DEFAULT);

-        ReplicatedMap map = new ReplicatedMap(null, channel, 50, "01", null);

-        map.put(UUID.randomUUID().toString(), localhost.getHostAddress());

-        for (int i = 0; i < 4; i++) {

-            Thread.sleep(3000);

-            System.out.println(localhost + ": " + map.keySet());

-        }

-        for (Object e : map.entrySetFull()) {

-            Map.Entry en = (Map.Entry)e;

-            AbstractReplicatedMap.MapEntry entry = (AbstractReplicatedMap.MapEntry)en.getValue();

-            System.out.println(entry);

-        }

-        map.breakdown();

-        channel.stop(Channel.DEFAULT);

-    }

-

-    private static String getBindAddress() {

-        try {

-            Enumeration<NetworkInterface> nis = NetworkInterface.getNetworkInterfaces();

-            while (nis.hasMoreElements()) {

-                NetworkInterface ni = nis.nextElement();

-                // The following APIs require JDK 1.6

-                /*

-                if (ni.isLoopback() || !ni.isUp() || !ni.supportsMulticast()) {

-                    continue;

-                }

-                */

-                Enumeration<InetAddress> ips = ni.getInetAddresses();

-                if (!ips.hasMoreElements()) {

-                    continue;

-                }

-                while (ips.hasMoreElements()) {

-                    InetAddress addr = ips.nextElement();

-                    if (addr.isLoopbackAddress()) {

-                        continue;

-                    }

-                    return addr.getHostAddress();

-                }

-            }

-            return InetAddress.getLocalHost().getHostAddress();

-        } catch (Exception e) {

-            logger.log(Level.SEVERE, e.getMessage(), e);

-            return null;

-        }

-    }

-

-}

+/*
+ * 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.tribes;
+
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import org.apache.catalina.tribes.Channel;
+import org.apache.catalina.tribes.ChannelException;
+import org.apache.catalina.tribes.group.GroupChannel;
+import org.apache.catalina.tribes.membership.McastService;
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.assembly.EndpointReference;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.LifeCycleListener;
+import org.apache.tuscany.sca.endpoint.tribes.AbstractReplicatedMap.MapEntry;
+import org.apache.tuscany.sca.endpoint.tribes.MapStore.MapListener;
+import org.apache.tuscany.sca.runtime.EndpointListener;
+import org.apache.tuscany.sca.runtime.EndpointRegistry;
+
+/**
+ * A replicated EndpointRegistry based on Apache Tomcat Tribes
+ */
+public class ReplicatedEndpointRegistry implements EndpointRegistry, LifeCycleListener, MapListener {
+    private final static Logger logger = Logger.getLogger(ReplicatedEndpointRegistry.class.getName());
+    private static final String MULTICAST_ADDRESS = "228.0.0.100";
+    private static final int MULTICAST_PORT = 50000;
+
+    private int port = MULTICAST_PORT;
+    private String address = MULTICAST_ADDRESS;
+    private String bind = null;
+    private int timeout = 50;
+
+    private final static String DEFAULT_DOMAIN_URI = "http://tuscany.apache.org/sca/1.1/domains/default";
+    private String domainURI = DEFAULT_DOMAIN_URI;
+    private List<EndpointReference> endpointreferences = new CopyOnWriteArrayList<EndpointReference>();
+    private List<EndpointListener> listeners = new CopyOnWriteArrayList<EndpointListener>();
+
+    private ExtensionPointRegistry registry;
+    private ReplicatedMap map;
+
+    private static final Channel createChannel(String address, int port, String bindAddress) {
+
+        //create a channel
+        GroupChannel channel = new GroupChannel();
+        McastService mcastService = (McastService)channel.getMembershipService();
+        mcastService.setPort(port);
+        mcastService.setAddress(address);
+
+        // REVIEW: In my case, there are multiple IP addresses
+        // One for the WIFI and the other one for VPN. For some reason the VPN one doesn't support
+        // Multicast
+
+        if (bindAddress != null) {
+            mcastService.setBind(bindAddress);
+        } else {
+            mcastService.setBind(getBindAddress());
+        }
+
+        return channel;
+    }
+
+    public ReplicatedEndpointRegistry(ExtensionPointRegistry registry, Map<String, String> attributes) {
+        this.registry = registry;
+        String portStr = attributes.get("port");
+        if (portStr != null) {
+            port = Integer.parseInt(portStr);
+        }
+        String address = attributes.get("address");
+        if (address == null) {
+            address = MULTICAST_ADDRESS;
+        }
+        bind = attributes.get("bind");
+        String timeoutStr = attributes.get("timeout");
+        if (timeoutStr != null) {
+            timeout = Integer.parseInt(timeoutStr);
+        }
+        // start();
+    }
+
+    public ReplicatedEndpointRegistry(String domainURI) {
+        this.domainURI = domainURI;
+        // start();
+    }
+
+    public void start() {
+        if (map != null) {
+            throw new IllegalStateException("The registry has already been started");
+        }
+        map =
+            new ReplicatedMap(null, createChannel(address, port, bind), timeout, this.domainURI,
+                              new ClassLoader[] {ReplicatedEndpointRegistry.class.getClassLoader()});
+        map.addListener(this);
+        try {
+            map.getChannel().start(Channel.DEFAULT);
+        } catch (ChannelException e) {
+            throw new IllegalStateException(e);
+        }
+    }
+
+    public void stop() {
+        if (map != null) {
+            map.removeListener(this);
+            Channel channel = map.getChannel();
+            map.breakdown();
+            try {
+                channel.stop(Channel.DEFAULT);
+            } catch (ChannelException e) {
+                throw new IllegalStateException(e);
+            }
+            map = null;
+        }
+    }
+
+    public void addEndpoint(Endpoint endpoint) {
+        map.put(endpoint.getURI(), endpoint);
+        logger.info("Add endpoint - " + endpoint);
+    }
+
+    public void addEndpointReference(EndpointReference endpointReference) {
+        endpointreferences.add(endpointReference);
+        logger.info("Add endpoint reference - " + endpointReference);
+    }
+
+    public void addListener(EndpointListener listener) {
+        listeners.add(listener);
+    }
+
+    /**
+     * Parse the component/service/binding URI into an array of parts (componentURI, serviceName, bindingName)
+     * @param uri
+     * @return
+     */
+    private String[] parse(String uri) {
+        String[] names = new String[3];
+        int index = uri.lastIndexOf('#');
+        if (index == -1) {
+            names[0] = uri;
+        } else {
+            names[0] = uri.substring(0, index);
+            String str = uri.substring(index + 1);
+            if (str.startsWith("service-binding(") && str.endsWith(")")) {
+                str = str.substring("service-binding(".length(), str.length() - 1);
+                String[] parts = str.split("/");
+                if (parts.length != 2) {
+                    throw new IllegalArgumentException("Invalid service-binding URI: " + uri);
+                }
+                names[1] = parts[0];
+                names[2] = parts[1];
+            } else if (str.startsWith("service(") && str.endsWith(")")) {
+                str = str.substring("service(".length(), str.length() - 1);
+                names[1] = str;
+            } else {
+                throw new IllegalArgumentException("Invalid component/service/binding URI: " + uri);
+            }
+        }
+        return names;
+    }
+
+    private boolean matches(String target, String uri) {
+        String[] parts1 = parse(target);
+        String[] parts2 = parse(uri);
+        for (int i = 0; i < parts1.length; i++) {
+            if (parts1[i] == null || parts1[i].equals(parts2[i])) {
+                continue;
+            } else {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    public List<Endpoint> findEndpoint(EndpointReference endpointReference) {
+        List<Endpoint> foundEndpoints = new ArrayList<Endpoint>();
+
+        logger.info("Find endpoint for reference - " + endpointReference);
+
+        if (endpointReference.getReference() != null) {
+            Endpoint targetEndpoint = endpointReference.getTargetEndpoint();
+            for (Object v : map.values()) {
+                Endpoint endpoint = (Endpoint)v;
+                // TODO: implement more complete matching
+                if (matches(targetEndpoint.getURI(), endpoint.getURI())) {
+                    MapEntry entry = map.getInternal(endpoint.getURI());
+                    if (!isLocal(entry)) {
+                        endpoint.setRemote(true);
+                    }
+                    // if (!entry.isPrimary()) {
+                    endpoint.setExtensionPointRegistry(registry);
+                    // }
+                    foundEndpoints.add(endpoint);
+                    logger.info("Found endpoint with matching service  - " + endpoint);
+                }
+                // else the service name doesn't match
+            }
+        }
+        return foundEndpoints;
+    }
+
+    private boolean isLocal(MapEntry entry) {
+        return entry.getPrimary().equals(map.getChannel().getLocalMember(false));
+    }
+
+    public List<EndpointReference> findEndpointReference(Endpoint endpoint) {
+        return endpointreferences;
+    }
+
+    public Endpoint getEndpoint(String uri) {
+        return (Endpoint)map.get(uri);
+    }
+
+    public List<EndpointReference> getEndpointRefereneces() {
+        return endpointreferences;
+    }
+
+    public List<Endpoint> getEndpoints() {
+        return new ArrayList(map.values());
+    }
+
+    public List<EndpointListener> getListeners() {
+        return listeners;
+    }
+
+    public void removeEndpoint(Endpoint endpoint) {
+        map.remove(endpoint.getURI());
+        logger.info("Remove endpoint - " + endpoint);
+    }
+
+    public void removeEndpointReference(EndpointReference endpointReference) {
+        endpointreferences.remove(endpointReference);
+        logger.info("Remove endpoint reference - " + endpointReference);
+    }
+
+    public void removeListener(EndpointListener listener) {
+        listeners.remove(listener);
+    }
+
+    public void updateEndpoint(String uri, Endpoint endpoint) {
+        Endpoint oldEndpoint = getEndpoint(uri);
+        if (oldEndpoint == null) {
+            throw new IllegalArgumentException("Endpoint is not found: " + uri);
+        }
+        map.put(endpoint.getURI(), endpoint);
+    }
+
+    public void entryAdded(Object key, Object value) {
+        MapEntry entry = (MapEntry)value;
+        if (!isLocal(entry)) {
+            logger.info("Remote endpoint added: " + entry.getValue());
+        }
+        Endpoint newEp = (Endpoint)entry.getValue();
+        for (EndpointListener listener : listeners) {
+            listener.endpointAdded(newEp);
+        }
+    }
+
+    public void entryRemoved(Object key, Object value) {
+        MapEntry entry = (MapEntry)value;
+        if (!isLocal(entry)) {
+            logger.info("Remote endpoint removed: " + entry.getValue());
+        }
+        Endpoint oldEp = (Endpoint)entry.getValue();
+        for (EndpointListener listener : listeners) {
+            listener.endpointRemoved(oldEp);
+        }
+    }
+
+    public void entryUpdated(Object key, Object oldValue, Object newValue) {
+        MapEntry oldEntry = (MapEntry)oldValue;
+        MapEntry newEntry = (MapEntry)newValue;
+        if (!isLocal(newEntry)) {
+            logger.info("Remote endpoint updated: " + newEntry.getValue());
+        }
+        Endpoint oldEp = (Endpoint)oldEntry.getValue();
+        Endpoint newEp = (Endpoint)newEntry.getValue();
+        for (EndpointListener listener : listeners) {
+            listener.endpointUpdated(oldEp, newEp);
+        }
+    }
+
+    public static void main(String[] args) throws Exception {
+        //create a channel
+        GroupChannel channel = new GroupChannel();
+        McastService mcastService = (McastService)channel.getMembershipService();
+        mcastService.setPort(MULTICAST_PORT);
+        mcastService.setAddress(MULTICAST_ADDRESS);
+
+        InetAddress localhost = InetAddress.getLocalHost();
+
+        // REVIEW: In my case, there are multiple IP addresses
+        // One for the WIFI and the other one for VPN. For some reason the VPN one doesn't support
+        // Multicast
+
+        // You can use "route add 228.0.0.0 mask 252.0.0.0 192.168.1.100"
+        mcastService.setBind(getBindAddress());
+        channel.start(Channel.DEFAULT);
+        ReplicatedMap map = new ReplicatedMap(null, channel, 50, "01", null);
+        map.put(UUID.randomUUID().toString(), localhost.getHostAddress());
+        for (int i = 0; i < 4; i++) {
+            Thread.sleep(3000);
+            System.out.println(localhost + ": " + map.keySet());
+        }
+        for (Object e : map.entrySetFull()) {
+            Map.Entry en = (Map.Entry)e;
+            AbstractReplicatedMap.MapEntry entry = (AbstractReplicatedMap.MapEntry)en.getValue();
+            System.out.println(entry);
+        }
+        map.breakdown();
+        channel.stop(Channel.DEFAULT);
+    }
+
+    private static String getBindAddress() {
+        try {
+            Enumeration<NetworkInterface> nis = NetworkInterface.getNetworkInterfaces();
+            while (nis.hasMoreElements()) {
+                NetworkInterface ni = nis.nextElement();
+                // The following APIs require JDK 1.6
+                /*
+                if (ni.isLoopback() || !ni.isUp() || !ni.supportsMulticast()) {
+                    continue;
+                }
+                */
+                Enumeration<InetAddress> ips = ni.getInetAddresses();
+                if (!ips.hasMoreElements()) {
+                    continue;
+                }
+                while (ips.hasMoreElements()) {
+                    InetAddress addr = ips.nextElement();
+                    if (addr.isLoopbackAddress()) {
+                        continue;
+                    }
+                    return addr.getHostAddress();
+                }
+            }
+            return InetAddress.getLocalHost().getHostAddress();
+        } catch (Exception e) {
+            logger.log(Level.SEVERE, e.getMessage(), e);
+            return null;
+        }
+    }
+
+}