servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gno...@apache.org
Subject svn commit: r411206 - /incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java
Date Fri, 02 Jun 2006 16:34:55 GMT
Author: gnodet
Date: Fri Jun  2 09:34:55 2006
New Revision: 411206

URL: http://svn.apache.org/viewvc?rev=411206&view=rev
Log:
Can only send asynchronously DONE or ERROR exchanges

Modified:
    incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java

Modified: incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java?rev=411206&r1=411205&r2=411206&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java
(original)
+++ incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/EndpointDeliveryChannel.java
Fri Jun  2 09:34:55 2006
@@ -75,11 +75,8 @@
     }
 
     public void send(MessageExchange exchange) throws MessagingException {
-        if (exchange instanceof InOut || exchange instanceof InOptionalOut) {
-            // Done status can only be send asynchronously
-            if (exchange.getStatus() != ExchangeStatus.DONE) {
-                throw new UnsupportedOperationException("Asynchonous in-out are not supported");
-            }
+        if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
+            throw new UnsupportedOperationException("Asynchonous send of active exchanges
are not supported");
         }
         BaseLifeCycle lf = (BaseLifeCycle) endpoint.getServiceUnit().getComponent().getLifeCycle();
         lf.sendConsumerExchange(exchange, endpoint);



Mime
View raw message