You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by de...@apache.org on 2004/12/21 07:12:42 UTC
svn commit: r122945 - /webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java
Author: deepal
Date: Mon Dec 20 22:12:40 2004
New Revision: 122945
URL: http://svn.apache.org/viewcvs?view=rev&rev=122945
Log:
Modified:
webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java
Modified: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java?view=diff&rev=122945&p1=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java&r1=122944&p2=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java&r2=122945
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java (original)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/clientapi/Call.java Mon Dec 20 22:12:40 2004
@@ -147,6 +147,7 @@
msgctx.setEnvelope(envelope);
OutputStream out = urlConnect.getOutputStream();
+
msgctx.setProperty(MessageContext.TRANSPORT_DATA, out);
msgctx.setProperty(MessageContext.TRANSPORT_TYPE, TransportSenderLocator.TRANSPORT_HTTP);
msgctx.setProperty(MessageContext.REQUEST_URL, url);
@@ -179,7 +180,7 @@
final AxisEngine engine = new AxisEngine(registry);
urlConnect.setDoOutput(true);
- MessageContext msgctx = new MessageContext(registry);
+ final MessageContext msgctx = new MessageContext(registry);
msgctx.setEnvelope(envelope);
OutputStream out = urlConnect.getOutputStream();
@@ -193,21 +194,20 @@
*/
if(blocked){
Runnable runnable = new Runnable() {
+ MessageContext response;
public void run() {
try {
-
- //todo find a way to get msg id
- correlator.addCorrelationInfo("MSGID",callback);
+ correlator.addCorrelationInfo(msgctx.getMessageID(),callback);
log.info("Starting new Thread ");
- MessageContext response = createIncomingMessageContext(urlConnect.getInputStream(), engine);
+ response= createIncomingMessageContext(urlConnect.getInputStream(), engine);
response.setServerSide(false);
engine.receive(response);
SOAPEnvelope envelope = response.getEnvelope();
//todo craete AsyncResult here
AsyncResult result = null;
- correlator.getCorrelationInfo("MSGID").onComplete(result);
+ correlator.getCorrelationInfo(response.getMessageID()).onComplete(result);
} catch (Exception e) {
- correlator.getCorrelationInfo("MSGID").reportError(e);
+ correlator.getCorrelationInfo(response.getMessageID()).reportError(e);
}
}
};