try {
log.info("Testing TCP stock service...");
GetQuote tester = new GetQuote();
tester.getQuote(new String [] { "-ltcp://localhost:8088", "XXX" });
String symbol = "XXX"; // args[0] ;
EngineConfiguration defaultConfig =
(new DefaultEngineConfigurationFactory()).
getClientEngineConfig();
SimpleProvider config = new SimpleProvider(defaultConfig);
SimpleTargetedChain c = new SimpleTargetedChain(new TCPSender());
config.deployTransport("tcp", c);
Service service = new Service(config);
Call call = (Call) service.createCall();
call.setTargetEndpointAddress( new URL("tcp://localhost:8088") );
call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
call.setReturnType( XMLType.XSD_FLOAT );
Object ret = call.invoke(
"urn:xmltoday-delayed-quotes", "getQuote",
new Object[] {symbol} );
if (ret instanceof Float) {
Float res = (Float) ret;
assertEquals("TestTCPTransportSample: stock price should be 55.25 +/- 0.000001", res.floatValue(), 55.25, 0.000001);
} else {
throw new AssertionFailedError("Bad return value from TCP stock test: "+ret);
}
}
// }
catch( Exception e ) {
e.printStackTrace();
throw new AssertionFailedError("Fault returned from TCP stock test: "+e);
}