From 19c5d85b1c029029f345b7300eacd4894a50cb14 Mon Sep 17 00:00:00 2001
From: rfeng <rfeng@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 20 Apr 2011 22:34:51 +0000
Subject: Allow the look up of endpoint address by component/service/binding
 name from the Node API

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1095537 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/tuscany/sca/node/impl/NodeImpl.java | 34 ++++++++++++++++++++++
 1 file changed, 34 insertions(+)

(limited to 'sca-java-2.x/trunk/modules/node-impl/src/main/java/org/apache')

diff --git a/sca-java-2.x/trunk/modules/node-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java b/sca-java-2.x/trunk/modules/node-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
index b41237b5ea..fc219588c6 100644
--- a/sca-java-2.x/trunk/modules/node-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
+++ b/sca-java-2.x/trunk/modules/node-impl/src/main/java/org/apache/tuscany/sca/node/impl/NodeImpl.java
@@ -365,4 +365,38 @@ public class NodeImpl implements Node, NodeExtension {
         return contributions;
     }
 
+    @Override
+    public String getEndpointAddress(String serviceBindingName) {
+        if (serviceBindingName == null) {
+            throw new IllegalArgumentException("Service binding name cannot be null");
+        }
+        
+        // Calculate the names for compoment/service/binding
+        String[] parts = serviceBindingName.split("/");
+        String componentName = parts[0];
+        String serviceName = parts.length >= 2 ? parts[1] : null;
+        String bindingName = parts.length >= 3 ? parts[2] : serviceName;
+
+        if (domainComposite != null) {
+            for (Component component : domainComposite.getComponents()) {
+                if (!component.getName().equals(componentName)) {
+                    continue;
+                }
+                for (Service service : component.getServices()) {
+                    if (serviceName != null && !service.getName().equals(serviceName)) {
+                        continue;
+                    }
+                    if (service instanceof RuntimeComponentService) {
+                        for (Endpoint ep : ((RuntimeComponentService)service).getEndpoints()) {
+                            if (bindingName == null || bindingName.equals(ep.getBinding().getName())) {
+                                return ep.getDeployedURI();
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
 }
-- 
cgit v1.2.3