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);