Message msg = msgContext.getRequestMessage();
byte[] buf = (byte[]) msg.getSOAPPartAsBytes();
boolean timedOut = false;
try {
FileOutputStream fos = new FileOutputStream( "xml" + nextNum + ".req" );
fos.write( buf );
fos.close();
}
catch( Exception e ) {
e.printStackTrace();
}
long timeout = Long.MAX_VALUE;
if (msgContext.getTimeout()!=0)
timeout=(new Date()).getTime()+msgContext.getTimeout();
for (; timedOut == false;) {
try {
Thread.sleep( 100 );
File file = new File( "xml" + nextNum + ".res" );
if ((new Date().getTime())>=timeout)
timedOut = true;
if ( !file.exists() ) continue ;
Thread.sleep( 100 ); // let the other side finish writing
FileInputStream fis = new FileInputStream( "xml" + nextNum + ".res" );
msg = new Message( fis );
msg.getSOAPPartAsBytes(); // just flush the buffer
fis.close();
Thread.sleep( 100 );
(new File("xml" + nextNum + ".res")).delete();
msgContext.setResponseMessage( msg );
break ;
}
catch( Exception e ) {
// File not there - just loop
}
}
nextNum++ ;
if (timedOut)
throw new AxisFault("timeout");
