<%@ page import="org.apache.sandesha.server.*,org.apache.sandesha.interop.testclient.*,org.apache.sandesha.client.ClientStorageManager,org.apache.sandesha.ws.rm.providers.RMProvider,javax.servlet.jsp.*, java.io.Writer, java.io.PrintWriter, org.apache.sandesha.IStorageManager, org.apache.sandesha.Constants, org.apache.axis.SimpleChain, java.util.Properties, java.io.InputStream, java.io.IOException, org.apache.sandesha.ws.rm.providers.RMClientProvider"%> <%@ page contentType="text/html;charset=UTF-8" language="java" %> <% out.println(""); out.println(""); /////////////////////Load Properties/////////////////////////// String ip=null; String port=null; String warName=null; String defaultTarget=null; String defaultAsyncEndPoint=null; Properties properties = new Properties(); try { ClassLoader cl = this.getClass().getClassLoader(); InputStream is = cl.getResourceAsStream("sandesha-interop.properties"); properties.load(is); ip=properties.getProperty("IP"); port=properties.getProperty("PORT"); warName=properties.getProperty("WAR_NAME"); defaultTarget="http://"+ip+":"+port+"/"+warName+"/services/RMInteropService"; defaultAsyncEndPoint="http://"+ip+":"+port+"/"+warName+"/services/RMService"; } catch (IOException e) { e.printStackTrace(); } ResponseWriter writer = new ResponseWriter (response.getWriter()); /////////////////////////////////////////////////////////////// %> Welcome to Apache Sandesha Innterop Test

Apache Sandesha Interop Testing

Server Endpoint<%=defaultTarget%>

WSDL

Interop Guide



Test Client

Target
Operation
wsrm:AcksTo
wsa:From
wsa:ReplyTo
wsa:FaultTo
Send Offer
No. of Messages

<% out.flush();%> <% runTest(interopBean,writer,defaultAsyncEndPoint); writer.flush(); %> <%! public void runTest(InteropBean bean,ResponseWriter writer,String defaultAsyncEndPoint) throws Exception { // System.out.println("AcksTo "+bean.getAcksTo()); // System.out.println("FaultTo "+bean.getFaultto()); // System.out.println("From "+bean.getFrom()); // System.out.println("No of Msf "+bean.getNoOfMsgs()); // System.out.println("Opertation "+bean.getOperation()); // System.out.println("ReplyTo"+bean.getReplyto()); // System.out.println("Source "+bean.getSourceURL()); // System.out.println("Target "+bean.getTarget()); // System.out.println("Offer "+bean.getOffer()); String to = null; if(bean!=null){ to = bean.getTarget(); bean.setSourceURL(defaultAsyncEndPoint); } if(to!=null) { writer.write("

Starting Test .......

"); writer.flush(); InteropCallback callback = new InteropCallback (writer); ClientStorageManager csm = new ClientStorageManager (); csm.setCallback(callback); RMProvider.setCallback(callback); RMClientProvider.setCallback(callback); Sender.setCallback(callback); //InteropStub stub= InteropStub.getInstance(); InteropStub stub= InteropStub.getInstance(); InteropStub.setCallback(callback); if(bean.getOperation().equalsIgnoreCase("ping")){ stub.runPing(bean); }else if(bean.getOperation().equalsIgnoreCase("echoString") ){ stub.runEcho(bean); } writer.write ("

Test Finished...

"); writer.write ("

"); csm.removeCallback(); RMProvider.removeCallback(); } } %>