Topic: 88 miles per hour, great scott Marty

Yeah I am realising quickly that im doing something pretty stupid... not sure what yet though. I upped the log4j logging level and saw a few exceptions in the axis call when trying to create the service (ConfigurationException service not found). I know very little about axis so im sure a little reading should get to the bottom of it.

Ill post my investigation.

I think I've missed the point of the binding stub, when i call the function stub.getMarketPricesCompressed i see in the axis logs that i get an exception saying that the service cannot be found. The function does however return the correct market prices (eventulaly).  Im however not sure what its doing internally. I know that the binding is essence the RPC proxy but im not sure how to set it up properly. I think the delay may actually be in it trying to search of the service properly. I need to do some more reading around what exactly a port/QName/service/Binding etc actually represents. Annoyingly im not really going to get any time to work on it until Saturday. The main thing is that I have a benchmark to work to now. 

Ok so about this gzip thing. Theres a good article about it that makes it sound really easy

http://wso2.org/library/3007

Until you relaise that the hand hint,

//get the Options object used by your client
Option options = client.getOptions();
//set the property
options.setProperty(org.apache.axis2.transport.http.HTTPConstants.MC_GZIP_REQUEST, Boolean.TRUE);

Doesn't explain what the client object is or how you get a hold of it. Can you just set org.apache.axis2.transport.http.HTTPConstants.MC_GZIP_REQUEST as a System variable and get away with doing it that way?

Ok so i was using axis1 i have now rewritten all of my proxy code to use axis2, it all looks pretty healthy, still with compression on im still only getting a round trip time of 200ms.

Not sure where i can squeeze a little more performance out of it. Im wondering if there are still some more options that im missing from my current configurations

Ok so i was using axis1 i have now rewritten all of my proxy code to use axis2, it all looks pretty healthy, still with compression on im still only getting a round trip time of 200ms.

Not sure where i can squeeze a little more performance out of it. Im wondering if there are still some more options that im missing from my current configurations

austinpodhorzer i have not but its what im going to do next.

I have a beasty connection through BE and the ping time to bf is 30-40ms. So yeah should be getting a lot less ive noticed that all the calls are not rpc style but doc style to thinking that might be something to do with it. I need to do some reading around soap to work out exactly what its doing in general.

If you can think of anything else then any help is much appreciated.

Nadat i think you right but theres not a whole load of code in the middle of the call, so i dont think there is that much i could have screwed up. (I think!)

So over the weekend i tried using Axis2 with ADB and Xmlbeans the ADB had serious problems working with the betdaq api so then rewrote it using xml beans. Betdaq calls take about 180ms and betfair 200ms.

As you can see the code the timing is around the proxy call so it should be pretty light. Any ideas? 

Here is the code,

protected BFExchangeServiceStub createExchangeBindingStub() throws ExchangeException {
    try {
        if (exchangeBindingStub == null) {
            exchangeBindingStub = new BFExchangeServiceStub(_sEndPointURLExchange);
            Options options = exchangeBindingStub._getServiceClient().getOptions();
            options.setProperty(HTTPConstants.MC_ACCEPT_GZIP, "true");
            exchangeBindingStub._getServiceClient().setOptions(options);
        }
        return exchangeBindingStub;
    } catch (AxisFault axisFault) {
        throw new ExchangeException("Axis is generally fucked and cant create exchange binding stub", axisFault);
    }
}

protected com.betfair.www.publicapi.types.exchange.v5.APIRequestHeader getHeaderExchange() {
    if (exchangeHeader == null) {
        exchangeHeader = com.betfair.www.publicapi.types.exchange.v5.APIRequestHeader.Factory.newInstance();
    }
    exchangeHeader.setClientStamp(new GregorianCalendar().getTimeInMillis());
    exchangeHeader.setSessionToken(sessionToken);
    return exchangeHeader;
} 

public String getMarketPricesCompressed(Integer marketId) throws ExchangeException {
    //Set up service calls
    BFExchangeServiceStub stubUK = createExchangeBindingStub();

    //Initialise request object
    GetMarketPricesCompressedDocument doc = GetMarketPricesCompressedDocument.Factory.newInstance();
    GetMarketPricesCompressedDocument.GetMarketPricesCompressed sub = GetMarketPricesCompressedDocument.GetMarketPricesCompressed.Factory.newInstance();
    GetMarketPricesCompressedReq req = GetMarketPricesCompressedReq.Factory.newInstance();

     //Initialise Header
    req.setHeader(getHeaderExchange());

    req.setMarketId(marketId);

    sub.setRequest(req);
    doc.setGetMarketPricesCompressed(sub);
    try {
        //Make the call
        PerfTimer timer = new PerfTimer();
        GetMarketPricesCompressedResp resp = stubUK.getMarketPricesCompressed(doc).getGetMarketPricesCompressedResponse().getResult();
        logger.info("bf time:"+timer.getElapsedTime());

        //Maintain the session
        setHeader(resp.getHeader());

        //Check for errors & return result
        if (resp.getErrorCode() != GetMarketPricesErrorEnum.OK) {
            throw new ExchangeException("Service Call Error - " + resp.getErrorCode());
        } else {
            return resp.getMarketPrices();
        }
    } catch (RemoteException e) {
       throw new ExchangeException("Error calling getMarketPricesCompressed", e);
    }
}

Also was just reading the docs is it worth doing something like this for the stub?

i.e. not just the gzip bit but the cached re-use of the httpClient objects?

String _sEndPointURLSecure = BmProperties.getInstance().getProperty(BetdaqPropertyKeys.BETDAQ_SECURE_ENDPOINT);
secureServiceStub = new SecureServiceStub(_sEndPointURLSecure);

MultiThreadedHttpConnectionManager conmgr = new MultiThreadedHttpConnectionManager();
conmgr.getParams().setDefaultMaxConnectionsPerHost(10);
HttpClient client = new HttpClient(conmgr);
secureServiceStub._getServiceClient().getLastOperationContext().setProperty(HTTPConstants.CACHED_HTTP_CLIENT, client);

Options options = secureServiceStub._getServiceClient().getOptions();
options.setProperty(HTTPConstants.MC_ACCEPT_GZIP, "true");
options.setProperty(HTTPConstants.REUSE_HTTP_CLIENT, "true");

Bingo, that did it, basically by using the REUSE_HTTP_CLIENT option then its working at roughly the ping speed. I think the extra 100ms was used to create a new HTTP client object which required a whole handshake of its own.

Thanks for all the help i hope this thread ends up being useful to anyone else trying to squeeze a little more juice from their axis engine.