[esb-java-dev] svn commit r17970 - branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services

[asankha]

Author: asankha
Date: Thu Jun  5 01:15:49 2008
New Revision: 17970
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=17970

Log:
fix ESBJAVA-516

Modified:
   
branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java

Modified: 
branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
URL: 
http://wso2.org/svn/browse/wso2/branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java?rev=17970&r1=17969&r2=17970&view=diff
==============================================================================
--- 
branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
      (original)
+++ 
branches/esb/java/1.7/esb/java/modules/core/src/main/java/org/wso2/esb/services/ProxyServiceAdmin.java
      Thu Jun  5 01:15:49 2008
@@ -32,6 +32,7 @@
 import org.apache.synapse.config.xml.XMLConfigConstants;
 import org.apache.synapse.core.axis2.ProxyService;
 import org.wso2.esb.services.tos.ProxyData;
+import org.wso2.esb.ServiceBusConfiguration;
 
 import javax.xml.namespace.QName;
 import java.util.*;
@@ -431,8 +432,14 @@
      */
     public void startProxyService(String proxyServiceName) throws AxisFault {
         log.debug("Starting/Re-starting proxy service : " + proxyServiceName);
-        getSynapseConfiguration().getProxyService(proxyServiceName)
-                .start(getSynapseConfiguration());
+        ProxyService proxy = 
getSynapseConfiguration().getProxyService(proxyServiceName);
+        List pinnedServers = proxy.getPinnedServers();
+
+        if (pinnedServers.isEmpty() || pinnedServers.contains(
+            ServiceBusConfiguration.getInstance().getServerName())) {
+
+            proxy.start(getSynapseConfiguration());
+        }
         log.info("Started/Re-started proxy service : " + proxyServiceName);
     }
 
@@ -446,8 +453,15 @@
      */
     public void stopProxyService(String proxyServiceName) throws AxisFault {
         log.debug("Stopping proxy service : " + proxyServiceName);
-        getSynapseConfiguration().getProxyService(proxyServiceName)
-                .stop(getSynapseConfiguration());
+
+        ProxyService proxy = 
getSynapseConfiguration().getProxyService(proxyServiceName);
+        List pinnedServers = proxy.getPinnedServers();
+
+        if (pinnedServers.isEmpty() || pinnedServers.contains(
+            ServiceBusConfiguration.getInstance().getServerName())) {
+
+            proxy.stop(getSynapseConfiguration());
+        }
         log.info("Stopped proxy service : " + proxyServiceName);
     }
 

_______________________________________________
Esb-java-dev mailing list
Esb-java-dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev