[wsas-java-dev] svn commit r1733 - in trunk/wsas/java/modules/clustering: . src/org/wso2/wsas/clustering

[svn at wso2.org]

Author: azeez
Date: Tue Apr  3 06:12:08 2007
New Revision: 1733

Modified:
   trunk/wsas/java/modules/clustering/clustering-codegen.xml
   trunk/wsas/java/modules/clustering/nodemanager.wsdl
   trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManagerClient.java
Log:
Changes to NodeManager codegen functionality

Modified: trunk/wsas/java/modules/clustering/clustering-codegen.xml
==============================================================================
--- trunk/wsas/java/modules/clustering/clustering-codegen.xml	(original)
+++ trunk/wsas/java/modules/clustering/clustering-codegen.xml	Tue Apr  3 06:12:08 2007
@@ -7,7 +7,8 @@
         <o>./target/generated</o>
         <p>org.wso2.wsas.clustering</p>
         <d>adb</d>
-        <u/>
+        <sn>NodeManager</sn>
+        <pn>NodeManagerSOAP11port_https</pn>
         <ns2p>http://www.wso2.org/types=org.wso2.www.types.client</ns2p>
         <Emp>org.wso2.wsas.clustering.client</Emp>
     </set>

Modified: trunk/wsas/java/modules/clustering/nodemanager.wsdl
==============================================================================
--- trunk/wsas/java/modules/clustering/nodemanager.wsdl	(original)
+++ trunk/wsas/java/modules/clustering/nodemanager.wsdl	Tue Apr  3 06:12:08 2007
@@ -361,22 +361,16 @@
     </wsdl:binding>
     <wsdl:service name="NodeManager">
         <wsdl:port name="NodeManagerSOAP11port_https" binding="ns0:NodeManagerSOAP11Binding">
-            <soap:address location="https://10.100.1.225:9443/soap/NodeManager"/>
+            <soap:address location="https://10.100.1.225:9443/services/NodeManager"/>
         </wsdl:port>
         <wsdl:port name="NodeManagerSOAP11port_http2" binding="ns0:NodeManagerSOAP11Binding">
-            <soap:address location="http://10.100.1.225:9762/soap/NodeManager"/>
+            <soap:address location="http://10.100.1.225:9762/services/NodeManager"/>
         </wsdl:port>
         <wsdl:port name="NodeManagerSOAP12port_https" binding="ns0:NodeManagerSOAP12Binding">
-            <soap12:address location="https://10.100.1.225:9443/soap/NodeManager"/>
+            <soap12:address location="https://10.100.1.225:9443/services/NodeManager"/>
         </wsdl:port>
         <wsdl:port name="NodeManagerSOAP12port_http2" binding="ns0:NodeManagerSOAP12Binding">
-            <soap12:address location="http://10.100.1.225:9762/soap/NodeManager"/>
-        </wsdl:port>
-        <wsdl:port name="NodeManagerHttpport1" binding="ns0:NodeManagerHttpBinding">
-            <http:address location="https://10.100.1.225:9443/rest/NodeManager"/>
-        </wsdl:port>
-        <wsdl:port name="NodeManagerHttpport3" binding="ns0:NodeManagerHttpBinding">
-            <http:address location="http://10.100.1.225:9762/rest/NodeManager"/>
+            <soap12:address location="http://10.100.1.225:9762/services/NodeManager"/>
         </wsdl:port>
     </wsdl:service>
 </wsdl:definitions>
\ No newline at end of file

Modified: trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManagerClient.java
==============================================================================
--- trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManagerClient.java	(original)
+++ trunk/wsas/java/modules/clustering/src/org/wso2/wsas/clustering/NodeManagerClient.java	Tue Apr  3 06:12:08 2007
@@ -15,8 +15,102 @@
  */
 package org.wso2.wsas.clustering;
 
+import org.apache.axis2.AxisFault;
+
+import java.rmi.RemoteException;
+
 /**
  * 
  */
 public class NodeManagerClient {
+    private NodeManagerStub stub;
+
+    public NodeManagerClient() throws AxisFault {
+//        System.setProperty("axis2.xml",
+//                           "/home/azeez/projects/wso2wsas/modules/samples/CommodityQuote/conf/axis2.xml");
+//        System.out.println("---" + System.getProperty("axis2.xml"));
+
+//        ConfigurationContext configContext =
+//                    ConfigurationContextFactory
+//                            .createConfigurationContextFromFileSystem(".",
+//                                                                      "/home/azeez/projects/wso2wsas/modules/samples/CommodityQuote/conf/axis2.xml");
+        stub = new NodeManagerStub("http://10.100.1.118:9762/services/WSO2WSASNodeManager");
+//        stub = new NodeManagerStub(configContext, "https://10.100.1.225:9443/soap/NodeManager");
+    }
+
+    private void reload() {
+        try {
+            NodeManagerStub.ReloadConfigurationResponse r = stub.reloadConfiguration();
+            if (r.get_return()) {
+                System.out.println("Reload response successful");
+                NodeManagerStub.CommitResponse commitResponse = stub.commit();
+                if (commitResponse.get_return()) {
+                    System.out.println("Successfully committed");
+                } else {
+                    System.out.println("Commit failed");
+                }
+            }
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        } catch (ReloadConfigurationFaultException e) {
+            e.printStackTrace();
+        } catch (CommitFaultException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void loadServiceGroup() {
+        try {
+            NodeManagerStub.LoadServiceGroup req = new NodeManagerStub.LoadServiceGroup();
+            req.setServiceGroupName("echo");
+            NodeManagerStub.LoadServiceGroupResponse resp = stub.loadServiceGroup(req);
+            if (resp.get_return()) {
+                NodeManagerStub.CommitResponse commitResponse = stub.commit();
+                if (commitResponse.get_return()) {
+                    System.out.println("Successfully committed");
+                } else {
+                    System.out.println("Commit failed");
+                }
+            }
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        } catch (CommitFaultException e) {
+            e.printStackTrace();
+        } catch (LoadServiceGroupFaultException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void unloadServiceGroup() {
+        try {
+            NodeManagerStub.UnloadServiceGroup req = new NodeManagerStub.UnloadServiceGroup();
+            req.setServiceGroupName("echo");
+            NodeManagerStub.UnloadServiceGroupResponse resp = stub.unloadServiceGroup(req);
+            if (resp.get_return()) {
+                NodeManagerStub.CommitResponse commitResponse = stub.commit();
+                if (commitResponse.get_return()) {
+                    System.out.println("Successfully committed");
+                } else {
+                    System.out.println("Commit failed");
+                }
+            }
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        } catch (CommitFaultException e) {
+            e.printStackTrace();
+        } catch (UnloadServiceGroupFaultException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void main(String[] args) {
+        try {
+            NodeManagerClient adminClient = new NodeManagerClient();
+            adminClient.reload();
+//            adminClient.loadServiceGroup();
+//            adminClient.unloadServiceGroup();
+        } catch (AxisFault axisFault) {
+            axisFault.printStackTrace();
+        }
+    }
 }