Create the runtime version of Endpoint2 for serialization

Serialize the EP using XML

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

2 files changed, 11 insertions, 2 deletions

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 e0c4430edb..70873310f2 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
@@ -38,11 +38,14 @@ import org.apache.tuscany.sca.assembly.EndpointReference2;
 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 {

     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 String domainURI;

+    private String domainURI = "default";

 

     private List<EndpointReference2> endpointreferences = new CopyOnWriteArrayList<EndpointReference2>();

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

@@ -64,6 +67,8 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry {
             mcastService.setBind(bindAddress);

         }

 

+        // mcastService.setBind("192.168.1.100");

+

         try {

             channel.start(Channel.DEFAULT);

         } catch (ChannelException e) {

@@ -72,6 +77,10 @@ public class ReplicatedEndpointRegistry implements EndpointRegistry {
         return channel;

     }

 

+    public ReplicatedEndpointRegistry() {

+        this("default");

+    }

+

     public ReplicatedEndpointRegistry(String domainURI) {

         this.domainURI = domainURI;

         map =

diff --git a/java/sca/modules/endpoint-tribes/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry b/java/sca/modules/endpoint-tribes/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
index 1d0e5ffe6d..1b7d0e7d89 100644
--- a/java/sca/modules/endpoint-tribes/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
+++ b/java/sca/modules/endpoint-tribes/src/main/resources/META-INF/services/org.apache.tuscany.sca.runtime.EndpointRegistry
@@ -14,4 +14,4 @@
 # 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
\ No newline at end of file
+org.apache.tuscany.sca.endpoint.tribes.ReplicatedEndpointRegistry;ranking=100
\ No newline at end of file