camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jans...@apache.org
Subject [1/3] camel git commit: CAMEL-9368 - don't fail the exchange if we actually specify to disconnect
Date Thu, 17 Dec 2015 19:30:50 GMT
Repository: camel
Updated Branches:
  refs/heads/camel-2.15.x 86f1de519 -> ec2d2394c
  refs/heads/camel-2.16.x 0535e4829 -> 9c8b250e4
  refs/heads/master 2c6cc6a7b -> 904a49b68


CAMEL-9368 - don't fail the exchange if we actually specify to disconnect


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/904a49b6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/904a49b6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/904a49b6

Branch: refs/heads/master
Commit: 904a49b68cf210c37dae9bacb82caed2dbf2d08e
Parents: 2c6cc6a
Author: Jonathan Anstey <janstey@gmail.com>
Authored: Thu Dec 17 15:55:09 2015 -0330
Committer: Jonathan Anstey <janstey@gmail.com>
Committed: Thu Dec 17 15:55:26 2015 -0330

----------------------------------------------------------------------
 .../camel/component/netty4/handlers/ClientChannelHandler.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/904a49b6/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
----------------------------------------------------------------------
diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
index 8905540..160adf4 100644
--- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
+++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/handlers/ClientChannelHandler.java
@@ -121,7 +121,10 @@ public class ClientChannelHandler extends SimpleChannelInboundHandler<Object>
{
             if (LOG.isDebugEnabled()) {
                 LOG.debug("Channel closed but no message received from address: {}", address);
             }
-            exchange.setException(new CamelExchangeException("No response received from remote
server: " + address, exchange));
+            // don't fail the exchange if we actually specify to disconnect
+            if (!configuration.isDisconnect()) {
+                exchange.setException(new CamelExchangeException("No response received from
remote server: " + address, exchange));
+            }
             // signal callback
             callback.done(false);
         }


Mime
View raw message