Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-11629 This closes #7327. Added Socket Write Timeout to InvokeHTTP 

Signed-off-by: Joe Witt <joewitt@apache.org>
This commit is contained in:
exceptionfactory 2023-06-01 17:12:38 -05:00 committed by Joe Witt
parent 3ef4439879
commit ec525b0437
No known key found for this signature in database
GPG Key ID: 9093BF854F811A1A
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
View File

@ -242,6 +242,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")
@ -505,6 +514,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,
@ -731,6 +741,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(),