svn commit: r497288 - /incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java

[mszefler]

Author: mszefler
Date: Wed Jan 17 18:20:29 2007
New Revision: 497288

URL: http://svn.apache.org/viewvc?view=rev&rev=497288
Log:
fixed waiters,

Modified:
    
incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java

Modified: 
incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java
URL: 
http://svn.apache.org/viewvc/incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java?view=diff&rev=497288&r1=497287&r2=497288
==============================================================================
--- 
incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java
 (original)
+++ 
incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/P2PMexContextImpl.java
 Wed Jan 17 18:20:29 2007
@@ -4,9 +4,6 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutorService;
-
-import javax.transaction.TransactionManager;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -75,6 +72,8 @@
                 }
             });
 
+            if (mex.getMessageExchangePattern() == 
MessageExchange.MessageExchangePattern.REQUEST_RESPONSE) 
+                _waiters.put(mex.getMessageExchangeId(),mex);
             // There is no way we can get a synchronous response.
             mex.replyAsync();
         } else {
@@ -110,8 +109,10 @@
         }
 
         odeMex.invoke(pmex.getRequest());
-        if (odeMex.getStatus() != MessageExchange.Status.ASYNC)
+        if (odeMex.getStatus() != MessageExchange.Status.ASYNC) {
+            _waiters.remove(pmex.getMessageExchangeId());
             handleResponse(pmex, odeMex);
+        }
 
         return odeMex;
     }