You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2015/12/17 20:30:52 UTC
[3/3] camel git commit: CAMEL-9368 - don't fail the exchange if we
actually specify to disconnect
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/ec2d2394
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ec2d2394
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ec2d2394
Branch: refs/heads/camel-2.15.x
Commit: ec2d2394c13a4936c8e5a80732e235038ccbca73
Parents: 86f1de5
Author: Jonathan Anstey <ja...@gmail.com>
Authored: Thu Dec 17 15:55:09 2015 -0330
Committer: Jonathan Anstey <ja...@gmail.com>
Committed: Thu Dec 17 16:00:34 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/ec2d2394/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 81c67cc..9e51053 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
@@ -116,7 +116,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);
}