svn commit: r554836 - /incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java

[ffang]

Author: ffang
Date: Mon Jul  9 22:48:28 2007
New Revision: 554836

URL: http://svn.apache.org/viewvc?view=rev&rev=554836
Log:
check MessageExchange is active before dispatch in JBI transport

Modified:
    
incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java

Modified: 
incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
URL: 
http://svn.apache.org/viewvc/incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java?view=diff&rev=554836&r1=554835&r2=554836
==============================================================================
--- 
incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
 (original)
+++ 
incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
 Mon Jul  9 22:48:28 2007
@@ -25,6 +25,7 @@
 import java.util.logging.Logger;
 
 import javax.jbi.messaging.DeliveryChannel;
+import javax.jbi.messaging.ExchangeStatus;
 import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.NormalizedMessage;
 import javax.xml.namespace.QName;
@@ -97,7 +98,9 @@
                         }
                     }
 
-                    if (exchange != null) {
+                    if (exchange != null 
+                        && exchange.getStatus() == ExchangeStatus.ACTIVE) {
+                        
                         try {
                             getLogger().info(new 
org.apache.cxf.common.i18n.Message(
                                     "DISPATCH.TO.SU", getLogger()).toString());
@@ -121,6 +124,7 @@
     }
     
     public void dispatch(MessageExchange exchange) throws IOException {
+        
         QName opName = exchange.getOperation(); 
         getLogger().info("dispatch method: " + opName);