samples.perf.PerfPortSoapBindingStub binding;
try {
binding = (samples.perf.PerfPortSoapBindingStub)
new samples.perf.PerfService_ServiceLocator().getPerfPort();
}
catch (javax.xml.rpc.ServiceException jre) {
if(jre.getLinkedCause()!=null)
jre.getLinkedCause().printStackTrace();
throw new junit.framework.AssertionFailedError("JAX-RPC ServiceException caught: " + jre);
}
assertNotNull("binding is null", binding);
// Time out after a minute
binding.setTimeout(60000);
binding._setProperty(org.apache.axis.client.Call.STREAMING_PROPERTY, Boolean.TRUE);
// Time out after a minute
binding.setTimeout(60000);
log.info(">>>> Warming up...");
pump(binding, 1);
log.info(">>>> Running volume tests...");
pump(binding, 100);
pump(binding, 1000);
pump(binding, 10000);
pump(binding, 100000);