please create a JIRA. Thanks Deepal
Michele Mazzucco wrote: >Hi all, > >I've got some more details: the error happens because the second message >is sent with an empty body. The workaround is to make the thread sleep >for (at least) 600 ms (unfortunately this is too much for my needs). Is >there any reason or is it a bug? If it is not a bug, why it is not >documented anywhere, since the tutorial for dual channel-non blocking >clients [1] does not use any sleep call? > > >Thanks, >Michele > >[1] http://ws.apache.org/axis2/1_0/userguide3.html#EchoNonBlockingDualClient > >Michele Mazzucco wrote: > > >>Hi all, >> >>I get a very strange error (on the client side) when I try to send >>multiple (equals, in my case: the submitted requests are the same of the >>"echo" sample) requests to my service. The error happens *only* when >>multiple requests are submitted, i.e., if the program sends only 1 >>requests no errors happen. >> >> >> >>INFO StreamRequestMyServiceClient:main - Sending [2] requests >>INFO StreamRequestMyServiceClient:send - Sent [2] requests >>INFO StreamRequestMyServiceClient$QospCallback:onComplete - Received >>respose [1/2] >>INFO StreamRequestMyServiceClient$QospCallback:onComplete - >><soapenv:Body >>xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/";><client:echo >>xmlns:client="http://org.ncl.ac.uk/qosp/clients/codestore"; >>xmlns:tns="http://ws.apache.org/axis2";><client:Text>QoSP Echo >>String</client:Text></client:echo></soapenv:Body> >>INFO StreamRequestMyServiceClient$QospCallback:onComplete - 1 are missing >>ERROR StreamRequestMyServiceClient:logException - ERROR!: >>ERROR StreamRequestMyServiceClient:logException - >>org.apache.axis2.AxisFault: unknown >> at >> org.apache.axis2.util.CallbackReceiver.receive(CallbackReceiver.java:65) >> at org.apache.axis2.engine.AxisEngine.receiveFault(AxisEngine.java:599) >> at >>org.apache.axis2.transport.http.HTTPTransportUtils.processHTTPPostRequest(HTTPTransportUtils.java:282) >> at >> org.apache.axis2.transport.http.HTTPWorker.service(HTTPWorker.java:238) >> at >>org.apache.axis2.transport.http.server.DefaultHttpServiceProcessor.doService(DefaultHttpServiceProcessor.java:177) >> at >> org.apache.http.protocol.HttpService.handleRequest(HttpService.java:123) >> at >>org.apache.axis2.transport.http.server.DefaultHttpServiceProcessor.run(DefaultHttpServiceProcessor.java:236) >> at >>edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) >> at >>edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) >> at java.lang.Thread.run(Thread.java:595) >>Caused by: java.lang.Exception: org.apache.axis2.AxisFault >> at >>org.apache.axis2.receivers.RawXMLINOnlyMessageReceiver.invokeBusinessLogic(RawXMLINOnlyMessageReceiver.java:104) >> at >>org.apache.axis2.receivers.AbstractInMessageReceiver.receive(AbstractInMessageReceiver.java:34) >> at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:503) >> at >>org.apache.axis2.transport.http.HTTPTransportUtils.processHTTPPostRequest(HTTPTransportUtils.java:284) >> at >> org.apache.axis2.transport.http.AxisServlet.doPost(AxisServlet.java:144) >> at javax.servlet.http.HttpServlet.service(HttpServlet.java:709) >> at javax.servlet.http.HttpServlet.service(HttpServlet.java:802) >> at >>org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:252) >> at >>org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173) >> at >>org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:213) >> at >>org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:178) >> at >>org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:126) >> at >>org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:105) >> at >>org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:107) >> at >>org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:148) >> at >>org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:869) >> at >>org.apache.coyote.http11.Http11BaseProtocol$Http11ConnectionHandler.processConnection(Http11BaseProtocol.java:667) >> at >>org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:527) >> at >>org.apache.tomcat.util.net.LeaderFollowerWorkerThread.runIt(LeaderFollowerWorkerThread.java:80) >> at >>org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:684) >> at java.lang.Thread.run(Thread.java:595) >> >> at org.apache.axis2.AxisFault.<init>(AxisFault.java:159) >> ... 10 more >> >> >> >> >> >> >> >> >>The following chunk of code submits the requests: >> >>/** >> * Sends [EMAIL PROTECTED] #requests} requests to the cluster manager. >> */ >>private final void send() { >> final OMElement payload = ClientUtils.getEchoOMElement(); >> >> // Creates and sets the options >> Options options = new Options(); >> >> String routerEPR = System.getProperty("qosp.manager.epr"); >> if (routerEPR == null) { >> throw new RuntimeException("Unable to get the router EPR"); >> } >> routerEPR = routerEPR.concat("MyService"); >> options.setTo(new EndpointReference(routerEPR)); >> >> >> options.setAction("urn:echo"); >> // The boolean flag informs the axis2 engine to use two separate >> // transport connection to retrieve the response. >> >> options.setTransportInProtocol(Constants.TRANSPORT_HTTP); >> options.setUseSeparateListener(true); >> >> options.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); >> >> ServiceClient sender = null; >> try { >> sender = new ServiceClient(); >> >> sender.engageModule(RoutingConstants.MODULE_ADDRESSING); >> sender.setOptions(options); >> >> QospCallback callback = new QospCallback(); >> for (int i = 0; i < this.requests.get(); i++) { >> sender.sendReceiveNonBlocking(payload, callback); >> } >> >> if (log.isInfoEnabled()) { >> log.info("Sent [" + this.requests.get() + "] requests"); >> } >> >> // Wait till the callback receives the response. >> while (!callback.isComplete()) { >> try { >> Thread.sleep(1000); >> } catch (InterruptedException e) { >> // >> } >> } >> >> } catch (AxisFault e) { >> if (log.isEnabledFor(Level.ERROR)) { >> logException(e); >> } >> } finally{ >> try { >> if (sender != null) >> sender.finalizeInvoke(); >> } catch (AxisFault axisFault) { >> // >> } >> } >> >> } //-- send() >> >>while this is the callback object used to retrieve asynchronous responses: >> >> >> >>/** >> * Sets the completion status. >> * >> * @param complete The completion status. >> */ >>@Override >>public void setComplete(boolean complete) { >> super.setComplete((requests.decrementAndGet() == 0)); >>} //-- setComplete() >> >> >>/** >> * Gets the completion status. >> * >> * @return The completion status. >> */ >>@Override >>public boolean isComplete() { >> return (requests.get() == 0); >>} //-- isComplete() >> >>/** >> * Handles asynchronous results. >> * >> * @param result The asynchronous result. >> */ >>@Override >>public void onComplete(AsyncResult result) { >> this.setComplete(true); >> if (log.isInfoEnabled()) { >> log.info("Received respose [" + (++ this.success) >> + "/" + this.toReceive + "]"); >> >> log.info(result.getResponseEnvelope().getBody().toString()); >> } >> if (this.isComplete()) { >> log.info("All requests are complete"); >> } else { >> log.info(requests.get() + " are missing"); >> } >>} //-- onComplete() >> >>/** >> * Handles asynchronous errors. >> * >> * @param e The exception. >> */ >>@Override >>public void onError(Exception e) { >> if (log.isEnabledFor(Level.ERROR)) { >> logException(e); >> } >>} //-- onError() >> >> >> >> >>Any idea? >> >>Thanks in advance, >>Michele >> >>--------------------------------------------------------------------- >>To unsubscribe, e-mail: [EMAIL PROTECTED] >>For additional commands, e-mail: [EMAIL PROTECTED] >> >> >> > >--------------------------------------------------------------------- >To unsubscribe, e-mail: [EMAIL PROTECTED] >For additional commands, e-mail: [EMAIL PROTECTED] > > > > > --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
