You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/02/13 13:52:26 UTC

svn commit: r377369 - in /incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client: DefaultServiceMixClient.java ServiceMixClientFacade.java

Author: gnodet
Date: Mon Feb 13 04:52:24 2006
New Revision: 377369

URL: http://svn.apache.org/viewcvs?rev=377369&view=rev
Log:
Throw an exception if the exchange can not be completed

Modified:
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/DefaultServiceMixClient.java
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/ServiceMixClientFacade.java

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/DefaultServiceMixClient.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/DefaultServiceMixClient.java?rev=377369&r1=377368&r2=377369&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/DefaultServiceMixClient.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/DefaultServiceMixClient.java Mon Feb 13 04:52:24 2006
@@ -197,6 +197,9 @@
         InOut exchange = createInOutExchange(resolver);
         populateMessage(exchange, exchangeProperties, inMessageProperties, content);
         boolean answer = sendSync(exchange);
+        if (!answer) {
+            throw new JBIException("Exchange aborted");
+        }
         Exception error = exchange.getError();
         if (error != null) {
             throw new JBIException(error);

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/ServiceMixClientFacade.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/ServiceMixClientFacade.java?rev=377369&r1=377368&r2=377369&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/ServiceMixClientFacade.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/client/ServiceMixClientFacade.java Mon Feb 13 04:52:24 2006
@@ -238,6 +238,9 @@
         InOut exchange = createInOutExchange(resolver);
         populateMessage(exchange, exchangeProperties, inMessageProperties, content);
         boolean answer = sendSync(exchange);
+        if (!answer) {
+            throw new JBIException("Exchange aborted");
+        }
         Exception error = exchange.getError();
         if (error != null) {
             throw new JBIException(error);