%@ 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
<% 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();
}
}
%>