Repository: nifi Updated Branches: refs/heads/master 3d546b8d8 -> d1ab17580
NIFI-5465: Set the Idle Timeout on jetty connectors to the same as the Request Timeout. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d1ab1758 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d1ab1758 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d1ab1758 Branch: refs/heads/master Commit: d1ab17580fe02766318e4a2d0ee5a76b0742d137 Parents: 3d546b8 Author: Mark Payne <[email protected]> Authored: Thu Jul 26 11:17:28 2018 -0400 Committer: Mark Payne <[email protected]> Committed: Mon Aug 6 10:33:24 2018 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/HandleHttpRequest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/d1ab1758/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java index b2a7ae2..ea27188 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java @@ -316,6 +316,9 @@ public class HandleHttpRequest extends AbstractProcessor { } http.setPort(port); + // If request timeout is longer than default Idle Timeout, then increase Idle Timeout as well. + http.setIdleTimeout(Math.max(http.getIdleTimeout(), requestTimeout)); + // add this connector server.setConnectors(new Connector[]{http}); } else { @@ -334,6 +337,9 @@ public class HandleHttpRequest extends AbstractProcessor { } https.setPort(port); + // If request timeout is longer than default Idle Timeout, then increase Idle Timeout as well. + https.setIdleTimeout(Math.max(https.getIdleTimeout(), requestTimeout)); + // add this connector server.setConnectors(new Connector[]{https}); }
