This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push:
new 39b063f49e NIFI-11629 This closes #7327. Added Socket Write Timeout to
InvokeHTTP
39b063f49e is described below
commit 39b063f49e132f3d656bb6f0e53ce429294e9fad
Author: exceptionfactory <[email protected]>
AuthorDate: Thu Jun 1 17:12:38 2023 -0500
NIFI-11629 This closes #7327. Added Socket Write Timeout to InvokeHTTP
Signed-off-by: Joe Witt <[email protected]>
(cherry picked from commit ec525b0437f6369a7dca56b9818475385d0d03a6)
---
.../java/org/apache/nifi/processors/standard/InvokeHTTP.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
index affc21b118..f15f5eb19d 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
@@ -244,6 +244,15 @@ public class InvokeHTTP extends AbstractProcessor {
.addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
.build();
+ public static final PropertyDescriptor SOCKET_WRITE_TIMEOUT = new
PropertyDescriptor.Builder()
+ .name("Socket Write Timeout")
+ .displayName("Socket Write Timeout")
+ .description("Maximum time to wait for write operations while
sending requests from a socket connection to the HTTP URL.")
+ .required(true)
+ .defaultValue("15 secs")
+ .addValidator(StandardValidators.TIME_PERIOD_VALIDATOR)
+ .build();
+
public static final PropertyDescriptor SOCKET_IDLE_TIMEOUT = new
PropertyDescriptor.Builder()
.name("idle-timeout")
.displayName("Socket Idle Timeout")
@@ -560,6 +569,7 @@ public class InvokeHTTP extends AbstractProcessor {
SSL_CONTEXT_SERVICE,
SOCKET_CONNECT_TIMEOUT,
SOCKET_READ_TIMEOUT,
+ SOCKET_WRITE_TIMEOUT,
SOCKET_IDLE_TIMEOUT,
SOCKET_IDLE_CONNECTIONS,
PROXY_CONFIGURATION_SERVICE,
@@ -833,6 +843,7 @@ public class InvokeHTTP extends AbstractProcessor {
okHttpClientBuilder.followRedirects(context.getProperty(RESPONSE_REDIRECTS_ENABLED).asBoolean());
okHttpClientBuilder.connectTimeout((context.getProperty(SOCKET_CONNECT_TIMEOUT).asTimePeriod(TimeUnit.MILLISECONDS).intValue()),
TimeUnit.MILLISECONDS);
okHttpClientBuilder.readTimeout(context.getProperty(SOCKET_READ_TIMEOUT).asTimePeriod(TimeUnit.MILLISECONDS).intValue(),
TimeUnit.MILLISECONDS);
+
okHttpClientBuilder.writeTimeout(context.getProperty(SOCKET_WRITE_TIMEOUT).asTimePeriod(TimeUnit.MILLISECONDS).intValue(),
TimeUnit.MILLISECONDS);
okHttpClientBuilder.connectionPool(
new ConnectionPool(
context.getProperty(SOCKET_IDLE_CONNECTIONS).asInteger(),
