public class org.apache.nifi.processors.standard.InvokeHTTP extends org.apache.nifi.processor.AbstractProcessor { public static final java.lang.String STATUS_CODE; public static final java.lang.String STATUS_MESSAGE; public static final java.lang.String RESPONSE_BODY; public static final java.lang.String REQUEST_URL; public static final java.lang.String REQUEST_DURATION; public static final java.lang.String RESPONSE_URL; public static final java.lang.String TRANSACTION_ID; public static final java.lang.String REMOTE_DN; public static final java.lang.String EXCEPTION_CLASS; public static final java.lang.String EXCEPTION_MESSAGE; public static final java.lang.String DEFAULT_CONTENT_TYPE; protected static final java.lang.String FORM_DATA_NAME_BASE; private static final java.util.regex.Pattern FORM_DATA_NAME_PARAMETER_PATTERN; private static final java.lang.String FORM_DATA_NAME_GROUP; private static final java.util.Set IGNORED_REQUEST_ATTRIBUTES; public static final org.apache.nifi.components.PropertyDescriptor HTTP_METHOD; public static final org.apache.nifi.components.PropertyDescriptor HTTP_URL; public static final org.apache.nifi.components.PropertyDescriptor HTTP2_DISABLED; public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE; public static final org.apache.nifi.components.PropertyDescriptor SOCKET_CONNECT_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor SOCKET_READ_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor SOCKET_IDLE_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor SOCKET_IDLE_CONNECTIONS; public static final org.apache.nifi.components.PropertyDescriptor PROXY_HOST; public static final org.apache.nifi.components.PropertyDescriptor PROXY_PORT; public static final org.apache.nifi.components.PropertyDescriptor PROXY_TYPE; public static final org.apache.nifi.components.PropertyDescriptor PROXY_USERNAME; public static final org.apache.nifi.components.PropertyDescriptor PROXY_PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_OAUTH2_ACCESS_TOKEN_PROVIDER; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_USERNAME; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_DIGEST_AUTHENTICATION_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_FAILURE_PENALIZATION_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_BODY_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_FORM_DATA_NAME; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_FORM_DATA_FILENAME_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_CHUNKED_TRANSFER_ENCODING_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_CONTENT_ENCODING; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_CONTENT_TYPE; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_DATE_HEADER_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_HEADER_ATTRIBUTES_PATTERN; public static final org.apache.nifi.components.PropertyDescriptor REQUEST_USER_AGENT; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_BODY_ATTRIBUTE_NAME; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_BODY_ATTRIBUTE_SIZE; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_BODY_IGNORED; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_CACHE_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_CACHE_SIZE; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_COOKIE_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_GENERATION_REQUIRED; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_FLOW_FILE_NAMING_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_HEADER_REQUEST_ATTRIBUTES_ENABLED; public static final org.apache.nifi.components.PropertyDescriptor RESPONSE_REDIRECTS_ENABLED; private static final org.apache.nifi.proxy.ProxySpec[] PROXY_SPECS; private static final org.apache.nifi.components.PropertyDescriptor PROXY_CONFIGURATION_SERVICE; public static final java.util.List PROPERTIES; public static final org.apache.nifi.processor.Relationship ORIGINAL; public static final org.apache.nifi.processor.Relationship RESPONSE; public static final org.apache.nifi.processor.Relationship RETRY; public static final org.apache.nifi.processor.Relationship NO_RETRY; public static final org.apache.nifi.processor.Relationship FAILURE; public static final java.util.Set RELATIONSHIPS; private static final java.time.format.DateTimeFormatter RFC_2616_DATE_TIME; private static final java.lang.String MULTIPLE_HEADER_DELIMITER; private static final org.apache.nifi.deprecation.log.DeprecationLogger deprecationLogger; private volatile java.util.Set dynamicPropertyNames; private volatile java.util.regex.Pattern requestHeaderAttributesPattern; private volatile boolean chunkedTransferEncoding; private volatile java.util.Optional oauth2AccessTokenProviderOptional; private final java.util.concurrent.atomic.AtomicReference okHttpClientAtomicReference; public void () { java.util.HashSet v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; specialinvoke v.()>(); v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v. = null; v. = 0; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; return; } protected java.util.List getSupportedPropertyDescriptors() { java.util.List v; org.apache.nifi.processors.standard.InvokeHTTP v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v = ; return v; } protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String) { org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.expression.AttributeExpression$ResultType v, v; java.lang.String v, v, v; boolean v, v; org.apache.nifi.components.Validator v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: java.lang.String; v = virtualinvoke v.("post:form"); if v == 0 goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(0); v = virtualinvoke v.(v); v = virtualinvoke v.("formDataName"); v = dynamicinvoke "makeConcatWithConstants" (v) ("Form Data \u0001"); v = virtualinvoke v.(v); v = ; v = staticinvoke (v, 1); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; label: return null; label: v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(0); v = virtualinvoke v.(v); v = ; v = staticinvoke (v, 1); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processors.standard.InvokeHTTP v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v = ; return v; } public void onPropertyModified(org.apache.nifi.components.PropertyDescriptor, java.lang.String, java.lang.String) { org.apache.nifi.components.PropertyDescriptor v, v; java.util.HashSet v; org.apache.nifi.processors.standard.InvokeHTTP v; java.lang.String v, v, v, v, v, v, v; boolean v, v, v; java.util.Set v, v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.components.PropertyDescriptor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); if v == 0 goto label; v = new java.util.HashSet; v = v.; specialinvoke v.(java.util.Collection)>(v); if v != null goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: if v != null goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (v); v. = v; goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v. = null; goto label; label: v = staticinvoke (v); v = staticinvoke (v); v. = v; label: return; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.regex.Matcher v; java.util.Map v; org.apache.nifi.proxy.ProxySpec[] v; java.util.Set v; java.lang.Object[] v, v, v; org.apache.nifi.components.ValidationContext v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTP v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.regex.Pattern v; java.lang.Boolean v; org.apache.nifi.components.ValidationResult v, v, v, v, v, v; java.util.Iterator v; org.apache.nifi.deprecation.log.DeprecationLogger v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; specialinvoke v.(int)>(3); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = ; v = virtualinvoke v.(); v[2] = v; v = ; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("{}[id={}] [{}] Property should be replaced with [{}] Property", v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; if v == 0 goto label; label: if v != 0 goto label; if v == 0 goto label; label: v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy Host and Port"); v = virtualinvoke v.(0); v = virtualinvoke v.("If Proxy Host or Proxy Port is set, both must be set"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; if v == 0 goto label; label: if v != 0 goto label; if v == 0 goto label; label: v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy User and Password"); v = virtualinvoke v.(0); v = virtualinvoke v.("If Proxy Username or Proxy Password is set, both must be set"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: if v == 0 goto label; if v != 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy"); v = virtualinvoke v.(0); v = virtualinvoke v.("If Proxy username is set, proxy host must be set"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; staticinvoke (v, v, v); v = 0; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = 1; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; if v == 0 goto label; if v != 0 goto label; v = newarray (java.lang.Object)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = staticinvoke ("[%s] is required when Form Data properties are configured and [%s] is enabled", v); v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: if v != 0 goto label; if v == 0 goto label; v = newarray (java.lang.Object)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = staticinvoke ("[%s] must be [true] when Form Data properties are configured and [%s] is configured", v); v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; if v == 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Authorization properties"); v = virtualinvoke v.(0); v = virtualinvoke v.("OAuth Authorization cannot be configured together with Username and Password properties"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return v; } public void setUpClient(org.apache.nifi.processor.ProcessContext) throws org.apache.nifi.security.util.TlsException, java.io.IOException { javax.net.ssl.SSLContext v; okhttp.Cache v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v; java.lang.Long v, v, v; java.net.Proxy v; org.apache.nifi.proxy.ProxyConfiguration v; okhttp.JavaNetCookieJar v; org.apache.nifi.processors.standard.util.ProxyAuthenticator v; javax.net.ssl.SSLSocketFactory v; org.apache.nifi.controller.ControllerService v; org.apache.nifi.processor.DataUnit v; java.lang.Double v; java.util.function.Supplier v; java.lang.String v, v, v; org.apache.nifi.processors.standard.http.CookieStrategy v; java.io.File v; okhttp.OkHttpClient v, v; javax.net.ssl.X509TrustManager v; okhttp.ConnectionPool v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTP v; int[] v; boolean v, v, v, v, v, v; java.net.CookiePolicy v; java.util.List v; java.net.CookieManager v; okhttp.Protocol v; okhttp.OkHttpClient$Builder v; java.util.concurrent.atomic.AtomicReference v, v; java.net.Proxy$Type v, v; int v, v, v, v, v, v, v; java.lang.Boolean v, v, v, v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.security.util.TlsConfiguration v; java.util.concurrent.TimeUnit v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; virtualinvoke v.(null); v = new okhttp.OkHttpClient; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.nifi.processors.standard.util.ProxyAuthenticator; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = new okhttp.Cache; v = staticinvoke (); specialinvoke v.(java.io.File,long)>(v, v); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; virtualinvoke v.(v, v); v = new okhttp.ConnectionPool; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; specialinvoke v.(int,long,java.util.concurrent.TimeUnit)>(v, v, v); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/ssl/SSLContextService;"); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, "Trust Manager not found"); virtualinvoke v.(v, v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = new java.net.CookieManager; specialinvoke v.()>(); v = ; virtualinvoke v.(v); v = new okhttp.JavaNetCookieJar; specialinvoke v.(java.net.CookieHandler)>(v); virtualinvoke v.(v); label: specialinvoke v.(v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void initOauth2AccessTokenProvider(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v; org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.controller.ControllerService v; java.util.Optional v, v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;"); interfaceinvoke v.(); v = staticinvoke (v); v. = v; goto label; label: v = staticinvoke (); v. = v; label: return; } private void setAuthenticator(okhttp.OkHttpClient$Builder, org.apache.nifi.processor.ProcessContext) { org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyValue v, v, v; com.burgstaller.okhttp.digest.DigestAuthenticator v; org.apache.nifi.processors.standard.InvokeHTTP v; java.lang.String v, v, v, v, v, v; boolean v, v; com.burgstaller.okhttp.digest.Credentials v; java.util.concurrent.ConcurrentHashMap v; org.apache.nifi.processor.ProcessContext v; java.util.List v; com.burgstaller.okhttp.AuthenticationCacheInterceptor v; com.burgstaller.okhttp.CachingAuthenticatorDecorator v; okhttp.OkHttpClient$Builder v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: okhttp.OkHttpClient$Builder; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); if v != 0 goto label; v = "true"; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v = new com.burgstaller.okhttp.digest.Credentials; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = new com.burgstaller.okhttp.digest.DigestAuthenticator; specialinvoke v.(com.burgstaller.okhttp.digest.Credentials)>(v); v = virtualinvoke v.(); v = new com.burgstaller.okhttp.AuthenticationCacheInterceptor; specialinvoke v.(java.util.Map)>(v); interfaceinvoke v.(v); v = new com.burgstaller.okhttp.CachingAuthenticatorDecorator; specialinvoke v.(okhttp.Authenticator,java.util.Map)>(v, v); virtualinvoke v.(v); label: return; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException { byte[] v; java.lang.Integer v; java.lang.Long v; java.util.Map v, v; okhttp.MediaType v, v; okhttp.Request v, v; org.apache.nifi.processors.standard.http.HttpMethod v, v; java.lang.Object[] v, v; org.apache.commons.io.input.TeeInputStream v, v; long v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v; okhttp.Response v; okhttp.Call v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v; java.util.UUID v; okhttp.RequestBody v; java.nio.charset.Charset v; int v, v, v; java.lang.Boolean v, v, v; java.lang.Class v; java.lang.Object v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; okhttp.ResponseBody v; java.lang.Exception v; java.lang.Throwable v, v; org.apache.nifi.provenance.ProvenanceReporter v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.URL v; org.apache.nifi.processors.standard.InvokeHTTP v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v, v; java.util.Optional v; okhttp.HttpUrl v; java.util.HashMap v; org.apache.nifi.logging.ComponentLog v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.processors.standard.http.FlowFileNamingStrategy v, v; org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream v, v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v, v, v; java.io.InputStream v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = interfaceinvoke v.(); if v == 0 goto label; return; label: v = specialinvoke v.(v, null); v = specialinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; return; label: if v == 0 goto label; v = interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (); v = null; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = new java.net.URL; specialinvoke v.(java.lang.String)>(v); v = specialinvoke v.(v, v, v, v); specialinvoke v.(v, v); v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, 1); label: v = staticinvoke (); v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: specialinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.("invokehttp.status.code", v); interfaceinvoke v.("invokehttp.status.message", v); v = virtualinvoke v.(); interfaceinvoke v.("invokehttp.request.url", v); v = ; v = staticinvoke (); v = v - v; v = virtualinvoke v.(v); v = staticinvoke (v); interfaceinvoke v.("invokehttp.request.duration", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("invokehttp.response.url", v); v = virtualinvoke v.(); interfaceinvoke v.("invokehttp.tx.id", v); if v == null goto label; v = interfaceinvoke v.(v, v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; if v == null goto label; v = specialinvoke v.(v); v = interfaceinvoke v.(v, v); label: v = specialinvoke v.(v); if v == 0 goto label; if v == 0 goto label; label: if v == null goto label; v = 1; goto label; label: v = 0; label: v = v; v = specialinvoke v.(v); if v == 0 goto label; if v == 0 goto label; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v = v; v = virtualinvoke v.(); if v == null goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = null; v = null; v = null; label: if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = null; label: v = v; if v == null goto label; if v == 0 goto label; if v == 0 goto label; v = new org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream; specialinvoke v.(int)>(v); v = v; v = new org.apache.commons.io.input.TeeInputStream; specialinvoke v.(java.io.InputStream,java.io.OutputStream)>(v, v); v = v; label: if v == 0 goto label; if v == null goto label; v = interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(v, v); v = specialinvoke v.(v); v = interfaceinvoke v.(v, v); v = ; v = specialinvoke v.(v); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(v); if v == null goto label; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: if v == null goto label; v = interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(v, v); label: v = ; v = staticinvoke (); v = v - v; v = virtualinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); goto label; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); label: if v == 0 goto label; if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = "invokehttp.response.body"; label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = newarray (byte)[v]; v = staticinvoke (v, v, 0); label: v = new java.lang.String; v = virtualinvoke v.(); v = specialinvoke v.(v); specialinvoke v.(byte[],int,int,java.nio.charset.Charset)>(v, 0, v, v); v = interfaceinvoke v.(v, v, v); v = ; v = staticinvoke (); v = v - v; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke ("Response Body Attribute Added [%s] Processing Duration [%d ms]", v); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); label: if v == null goto label; virtualinvoke v.(); label: if v == null goto label; virtualinvoke v.(); goto label; label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: if v == null goto label; virtualinvoke v.(); goto label; label: if v == null goto label; virtualinvoke v.(); label: throw v; label: specialinvoke v.(v, v, v, v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; if v != null goto label; interfaceinvoke v.("Request Processing failed", v); interfaceinvoke v.(); goto label; label: v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Request Processing failed: {}", v); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, "invokehttp.java.exception.class", v); v = virtualinvoke v.(); v = interfaceinvoke v.(v, "invokehttp.java.exception.message", v); v = ; interfaceinvoke v.(v, v); label: if v == null goto label; interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } private okhttp.Request configureRequest(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile, java.net.URL) { okhttp.Request$Builder v; java.net.URL v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.processors.standard.http.ContentEncodingStrategy v, v, v; boolean v, v, v, v; okhttp.Request v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processors.standard.http.HttpHeader v, v; java.util.Optional v, v; okhttp.RequestBody v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; java.util.function.Consumer v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.net.URL; v = new okhttp.Request$Builder; specialinvoke v.()>(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = "false"; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = v.; v = staticinvoke (v); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = ; if v != v goto label; v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = specialinvoke v.(v, v); v = specialinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v, v, v, v); goto label; label: v = null; goto label; label: v = null; label: virtualinvoke v.(v, v); specialinvoke v.(v, v, v); v = virtualinvoke v.(); return v; } private okhttp.RequestBody getRequestBodyToSend(org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processors.standard.http.ContentEncodingStrategy) { byte[] v; okhttp.MultipartBody$Builder v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.processors.standard.http.ContentEncodingStrategy v, v; java.util.Map v; okhttp.MediaType v; boolean v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; java.util.Set v, v; org.apache.nifi.processors.standard.InvokeHTTP$1 v; okhttp.MultipartBody v; java.util.regex.Pattern v; java.util.HashMap v; okhttp.RequestBody v; int v; java.lang.Boolean v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; java.lang.Object v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processors.standard.http.ContentEncodingStrategy; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = "application/octet-stream"; goto label; label: v = v; label: v = v; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("formDataName"); v = interfaceinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = v.; if v != 0 goto label; v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: v = new org.apache.nifi.processors.standard.InvokeHTTP$1; specialinvoke v.(org.apache.nifi.processors.standard.InvokeHTTP,java.lang.String,org.apache.nifi.processors.standard.http.ContentEncodingStrategy,org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,boolean)>(v, v, v, v, v, v); v = interfaceinvoke v.(); if v > 0 goto label; v = staticinvoke (v); if v == 0 goto label; label: v = new okhttp.MultipartBody$Builder; specialinvoke v.()>(); v = ; v = virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = null; if v == 0 goto label; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v); goto label; label: if v == 0 goto label; virtualinvoke v.(v, v, v); label: v = virtualinvoke v.(); return v; label: if v == 0 goto label; return v; label: v = newarray (byte)[0]; v = staticinvoke (v, null); return v; } private void setHeaderProperties(org.apache.nifi.processor.ProcessContext, okhttp.Request$Builder, org.apache.nifi.flowfile.FlowFile) { okhttp.Request$Builder v; java.time.ZonedDateTime v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v; java.util.regex.Matcher v, v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.Map v; java.time.ZoneOffset v; boolean v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; java.util.Set v, v, v; org.apache.nifi.processors.standard.http.HttpHeader v, v; java.util.regex.Pattern v, v, v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v; java.util.Iterator v, v; org.apache.nifi.processor.ProcessContext v; java.time.format.DateTimeFormatter v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: okhttp.Request$Builder; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = ; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v, v); goto label; label: v = v.; if v == null goto label; if v == null goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(""); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = ; v = interfaceinvoke v.(v); if v != 0 goto label; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v); goto label; label: return; } private void route(org.apache.nifi.flowfile.FlowFile, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession, org.apache.nifi.processor.ProcessContext, int) { org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v; org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.processor.Relationship v, v, v, v, v; int v, v; java.lang.Boolean v, v; boolean v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: int; v = specialinvoke v.(v); if v != 0 goto label; if v != null goto label; interfaceinvoke v.(); label: v = 0; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.(v, v); v = 1; label: v = specialinvoke v.(v); if v == 0 goto label; if v == null goto label; v = ; interfaceinvoke v.(v, v); label: if v == null goto label; if v != 0 goto label; v = ; interfaceinvoke v.(v, v); goto label; label: v = v / 100; if v != 5 goto label; if v == null goto label; v = interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, v); goto label; label: if v == null goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(v); label: v = ; interfaceinvoke v.(v, v); label: return; } private boolean isSuccess(int) { org.apache.nifi.processors.standard.InvokeHTTP v; int v, v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: int; v = v / 100; if v != 2 goto label; v = 1; goto label; label: v = 0; label: return v; } private void logRequest(org.apache.nifi.logging.ComponentLog, okhttp.Request) { okhttp.Request v; java.lang.Object[] v; java.net.URL v; org.apache.nifi.logging.ComponentLog v; okhttp.Headers v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.Map v; java.lang.String v, v; okhttp.HttpUrl v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.logging.ComponentLog; v := @parameter: okhttp.Request; v = interfaceinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); v[1] = v; interfaceinvoke v.("\nRequest to remote service:\n\t{}\n{}", v); label: return; } private void logResponse(org.apache.nifi.logging.ComponentLog, java.net.URL, okhttp.Response) { java.lang.Object[] v; java.net.URL v; org.apache.nifi.logging.ComponentLog v; okhttp.Headers v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.Map v; okhttp.Response v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.logging.ComponentLog; v := @parameter: java.net.URL; v := @parameter: okhttp.Response; v = interfaceinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); v[1] = v; interfaceinvoke v.("\nResponse from remote service:\n\t{}\n{}", v); label: return; } private java.lang.String getLogString(java.util.Map) { java.util.Iterator v; java.util.Set v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.Map v; int v; java.lang.Object v, v, v, v; java.lang.StringBuilder v; java.lang.String v; boolean v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: java.util.Map; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; virtualinvoke v.("\t"); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(": "); v = interfaceinvoke v.(); if v != 1 goto label; v = interfaceinvoke v.(0); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.("\n"); goto label; label: v = virtualinvoke v.(); return v; } private java.util.Map convertAttributesFromHeaders(okhttp.Response) { java.util.Set v; java.util.HashMap v; okhttp.Headers v; java.util.function.Consumer v; java.security.Principal v; org.apache.nifi.processors.standard.InvokeHTTP v; okhttp.Response v; java.lang.String v; okhttp.Handshake v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: okhttp.Response; v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); interfaceinvoke v.("invokehttp.remote.dn", v); label: return v; } private java.nio.charset.Charset getCharsetFromMediaType(okhttp.MediaType) { java.nio.charset.Charset v, v; org.apache.nifi.processors.standard.InvokeHTTP v; okhttp.MediaType v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: okhttp.MediaType; if v == null goto label; v = ; v = virtualinvoke v.(v); goto label; label: v = ; label: return v; } private static java.io.File getResponseCacheDirectory() throws java.io.IOException { java.nio.file.attribute.FileAttribute[] v; java.lang.Class v; java.lang.String v; java.nio.file.Path v; java.io.File v; v = class "Lorg/apache/nifi/processors/standard/InvokeHTTP;"; v = virtualinvoke v.(); v = newarray (java.nio.file.attribute.FileAttribute)[0]; v = staticinvoke (v, v); v = interfaceinvoke v.(); return v; } private org.apache.nifi.processors.standard.http.FlowFileNamingStrategy getFlowFileNamingStrategy(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.processor.ProcessContext v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; org.apache.nifi.processors.standard.http.FlowFileNamingStrategy v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); return v; } private java.lang.String getFileNameFromUrl(java.net.URL) { java.net.URL v; org.apache.nifi.processors.standard.InvokeHTTP v; int v, v; java.lang.String v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: java.net.URL; v = null; v = virtualinvoke v.(); v = staticinvoke (v, "/"); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(47); v = v + 1; v = virtualinvoke v.(v); label: return v; } private java.util.Optional findRequestMethod(java.lang.String) { org.apache.nifi.processors.standard.http.HttpMethod[] v; java.util.stream.Stream v, v; org.apache.nifi.processors.standard.InvokeHTTP v; java.util.function.Predicate v; java.util.Optional v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: java.lang.String; v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); return v; } private java.lang.String getRequestMethod(org.apache.nifi.context.PropertyContext, org.apache.nifi.flowfile.FlowFile) { org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v, v; org.apache.nifi.processors.standard.InvokeHTTP v; java.lang.String v, v, v; org.apache.nifi.context.PropertyContext v; v := @this: org.apache.nifi.processors.standard.InvokeHTTP; v := @parameter: org.apache.nifi.context.PropertyContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); return v; } static void () { org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v, v, v, v, v, v, v; java.time.format.DateTimeFormatter v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v, v, v; org.apache.nifi.processors.standard.http.CookieStrategy[] v; java.util.concurrent.TimeUnit v, v; org.apache.nifi.deprecation.log.DeprecationLogger v; org.apache.nifi.proxy.ProxySpec v, v; java.util.Locale v; java.util.HashSet v, v; org.apache.nifi.components.PropertyDescriptor[] v; java.lang.String[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v, v; org.apache.nifi.processor.Relationship[] v; java.util.function.Function v; java.lang.Boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.expression.AttributeExpression$ResultType v, v, v, v; java.util.regex.Pattern v, v, v; org.apache.nifi.components.AllowableValue[] v, v, v, v, v, v, v; org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.http.ContentEncodingStrategy v; org.apache.nifi.proxy.ProxySpec[] v, v; java.util.stream.Stream v, v; org.apache.nifi.processors.standard.http.HttpMethod v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object[] v, v; org.apache.nifi.processors.standard.http.FlowFileNamingStrategy[] v; java.util.function.IntFunction v; org.apache.nifi.processors.standard.http.CookieStrategy v; java.util.Set v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.http.FlowFileNamingStrategy v; v = staticinvoke ("post:form:(?.*)$"); = v; v = new java.util.HashSet; v = newarray (java.lang.String)[12]; v[0] = "invokehttp.status.code"; v[1] = "invokehttp.status.message"; v[2] = "invokehttp.response.body"; v[3] = "invokehttp.request.url"; v[4] = "invokehttp.response.url"; v[5] = "invokehttp.tx.id"; v[6] = "invokehttp.remote.dn"; v[7] = "invokehttp.java.exception.class"; v[8] = "invokehttp.java.exception.message"; v = ; v = virtualinvoke v.(); v[9] = v; v = ; v = virtualinvoke v.(); v[10] = v; v = ; v = virtualinvoke v.(); v[11] = v; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (v); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("HTTP Method"); v = virtualinvoke v.("HTTP request method (GET, POST, PUT, PATCH, DELETE, HEAD, OPTIONS). Arbitrary methods are also supported. Methods other than POST, PUT and PATCH will be sent without a message body."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Remote URL"); v = virtualinvoke v.("HTTP URL"); v = virtualinvoke v.("HTTP remote URL including a scheme of http or https, as well as a hostname or IP address with optional port and path elements."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("disable-http2"); v = virtualinvoke v.("HTTP/2 Disabled"); v = virtualinvoke v.("Disable negotiation of HTTP/2 protocol. HTTP/2 requires TLS. HTTP/1.1 protocol supported is required when HTTP/2 is disabled."); v = virtualinvoke v.(1); v = virtualinvoke v.("False"); v = newarray (java.lang.String)[2]; v[0] = "True"; v[1] = "False"; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SSL Context Service"); v = virtualinvoke v.("SSL Context Service provides trusted certificates and client certificates for TLS communication."); v = virtualinvoke v.(0); v = virtualinvoke v.(class "Lorg/apache/nifi/ssl/SSLContextService;"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Connection Timeout"); v = virtualinvoke v.("Socket Connect Timeout"); v = virtualinvoke v.("Maximum time to wait for initial socket connection to the HTTP URL."); v = virtualinvoke v.(1); v = virtualinvoke v.("5 secs"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Read Timeout"); v = virtualinvoke v.("Socket Read Timeout"); v = virtualinvoke v.("Maximum time to wait for receiving responses from a socket connection to the HTTP URL."); v = virtualinvoke v.(1); v = virtualinvoke v.("15 secs"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("idle-timeout"); v = virtualinvoke v.("Socket Idle Timeout"); v = virtualinvoke v.("Maximum time to wait before closing idle connections to the HTTP URL."); v = virtualinvoke v.(1); v = virtualinvoke v.("5 mins"); v = ; v = ; v = staticinvoke (1L, v, 2147483647L, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("max-idle-connections"); v = virtualinvoke v.("Socket Idle Connections"); v = virtualinvoke v.("Maximum number of idle connections to the HTTP URL."); v = virtualinvoke v.(1); v = virtualinvoke v.("5"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy Host"); v = virtualinvoke v.("Proxy Host and dependent properties are deprecated in favor of Proxy Configuration Service. Proxy Host can be configured using an IP address or DNS address."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy Port"); v = virtualinvoke v.("Proxy Port and dependent properties are deprecated in favor of Proxy Configuration Service. Port number for the configured Proxy Host address."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Proxy Type"); v = virtualinvoke v.("Proxy Type"); v = virtualinvoke v.("Proxy Type and dependent properties are deprecated in favor of Proxy Configuration Service. Proxy protocol type is not used"); v = virtualinvoke v.("http"); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("invokehttp-proxy-user"); v = virtualinvoke v.("Proxy Username"); v = virtualinvoke v.("Proxy Username and dependent properties are deprecated in favor of Proxy Configuration Service. Username to set when authenticating with a Proxy server."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("invokehttp-proxy-password"); v = virtualinvoke v.("Proxy Password"); v = virtualinvoke v.("Proxy Password and dependent properties are deprecated in favor of Proxy Configuration Service. Password to set when authenticating with a Proxy server."); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("oauth2-access-token-provider"); v = virtualinvoke v.("Request OAuth Access Token Provider"); v = virtualinvoke v.("Enables managed retrieval of OAuth Bearer Token applied to HTTP requests using the Authorization Header."); v = virtualinvoke v.(class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;"); v = virtualinvoke v.(0); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Basic Authentication Username"); v = virtualinvoke v.("Request Username"); v = virtualinvoke v.("The username provided for authentication of HTTP requests. Encoded using Base for HTTP Basic Authentication as described in RFC 7617."); v = virtualinvoke v.(0); v = staticinvoke ("^[\\x20-\\x39\\x3b-\\x7e\\x80-\\xff]+$"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Basic Authentication Password"); v = virtualinvoke v.("Request Password"); v = virtualinvoke v.("The password provided for authentication of HTTP requests. Encoded using Base for HTTP Basic Authentication as described in RFC 7617."); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v = staticinvoke ("^[\\x20-\\x7e\\x80-\\xff]+$"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Digest Authentication"); v = virtualinvoke v.("Request Digest Authentication Enabled"); v = virtualinvoke v.("Enable Digest Authentication on HTTP requests with Username and Password credentials as described in RFC 7616."); v = virtualinvoke v.(0); v = virtualinvoke v.("false"); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Penalize on \"No Retry\""); v = virtualinvoke v.("Request Failure Penalization Enabled"); v = virtualinvoke v.("Enable penalization of request FlowFiles when receiving HTTP response with a status code between 400 and 499."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("send-message-body"); v = virtualinvoke v.("Request Body Enabled"); v = virtualinvoke v.("Enable sending HTTP request body for PATCH, POST, or PUT methods."); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("form-body-form-name"); v = virtualinvoke v.("Request Multipart Form-Data Name"); v = virtualinvoke v.("Enable sending HTTP request body formatted using multipart/form-data and using the form name configured."); v = virtualinvoke v.(0); v = ; v = staticinvoke (v, 1); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[0]; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("set-form-filename"); v = virtualinvoke v.("Request Multipart Form-Data Filename Enabled"); v = virtualinvoke v.("Enable sending the FlowFile filename attribute as the filename parameter in the Content-Disposition Header for multipart/form-data HTTP requests."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Use Chunked Encoding"); v = virtualinvoke v.("Request Chunked Transfer-Encoding Enabled"); v = virtualinvoke v.("Enable sending HTTP requests with the Transfer-Encoding Header set to chunked, and disable sending the Content-Length Header. Transfer-Encoding applies to the body in HTTP/1.1 requests as described in RFC 7230 Section 3.3.1"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Content-Encoding"); v = virtualinvoke v.("Request Content-Encoding"); v = virtualinvoke v.("HTTP Content-Encoding applied to request body during transmission. The receiving server must support the selected encoding to avoid request failures."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(class "Lorg/apache/nifi/processors/standard/http/ContentEncodingStrategy;"); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Content-Type"); v = virtualinvoke v.("Request Content-Type"); v = newarray (java.lang.Object)[1]; v[0] = "application/octet-stream"; v = staticinvoke ("The Content-Type defaults to %s when not configured.", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("HTTP Content-Type Header applied to when sending an HTTP request body for PATCH, POST, or PUT methods. \u0001"); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("${\u0001}"); v = virtualinvoke v.(v); v = ; v = staticinvoke (v); v = virtualinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Include Date Header"); v = virtualinvoke v.("Request Date Header Enabled"); v = virtualinvoke v.("Enable sending HTTP Date Header on HTTP requests as described in RFC 7231 Section 7.1.1.2."); v = virtualinvoke v.(1); v = virtualinvoke v.("True"); v = newarray (java.lang.String)[2]; v[0] = "True"; v[1] = "False"; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Attributes to Send"); v = virtualinvoke v.("Request Header Attributes Pattern"); v = virtualinvoke v.("Regular expression that defines which attributes to send as HTTP headers in the request. If not defined, no attributes are sent as headers. Dynamic properties will be sent as headers. The dynamic property name will be the header key and the dynamic property value will be interpreted as expression language will be the header value."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Useragent"); v = virtualinvoke v.("Request User-Agent"); v = virtualinvoke v.("HTTP User-Agent Header applied to requests. RFC 7231 Section 5.5.3 describes recommend formatting."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Put Response Body In Attribute"); v = virtualinvoke v.("Response Body Attribute Name"); v = virtualinvoke v.("FlowFile attribute name used to write an HTTP response body for FlowFiles transferred to the Original relationship."); v = ; v = staticinvoke (v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Max Length To Put In Attribute"); v = virtualinvoke v.("Response Body Attribute Size"); v = virtualinvoke v.("Maximum size in bytes applied when writing an HTTP response body to a FlowFile attribute. Attributes exceeding the maximum will be truncated."); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.("256"); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[0]; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("ignore-response-content"); v = virtualinvoke v.("Response Body Ignored"); v = virtualinvoke v.("Disable writing HTTP response FlowFiles to Response relationship"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("use-etag"); v = virtualinvoke v.("Response Cache Enabled"); v = virtualinvoke v.("Enable HTTP response caching described in RFC 7234. Caching responses considers ETag and other headers."); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("etag-max-cache-size"); v = virtualinvoke v.("Response Cache Size"); v = virtualinvoke v.("Maximum size of HTTP response cache in bytes. Caching responses considers ETag and other headers."); v = virtualinvoke v.(1); v = virtualinvoke v.("10MB"); v = ; v = virtualinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); v = newarray (java.lang.String)[0]; v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("cookie-strategy"); v = virtualinvoke v.("Strategy for accepting and persisting HTTP cookies. Accepting cookies enables persistence across multiple requests."); v = virtualinvoke v.("Response Cookie Strategy"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Always Output Response"); v = virtualinvoke v.("Response Generation Required"); v = virtualinvoke v.("Enable generation and transfer of a FlowFile to the Response relationship regardless of HTTP response received."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("flow-file-naming-strategy"); v = virtualinvoke v.("Determines the strategy used for setting the filename attribute of FlowFiles transferred to the Response relationship."); v = virtualinvoke v.("Response FlowFile Naming Strategy"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Add Response Headers to Request"); v = virtualinvoke v.("Response Header Request Attributes Enabled"); v = virtualinvoke v.("Enable adding HTTP response headers as attributes to FlowFiles transferred to the Original relationship."); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.String)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Follow Redirects"); v = virtualinvoke v.("Response Redirects Enabled"); v = virtualinvoke v.("Enable following HTTP redirects sent with HTTP 300 series responses as described in RFC 7231 Section 6.4."); v = virtualinvoke v.(1); v = virtualinvoke v.("True"); v = newarray (java.lang.String)[2]; v[0] = "True"; v[1] = "False"; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = newarray (org.apache.nifi.proxy.ProxySpec)[2]; v = ; v[0] = v; v = ; v[1] = v; = v; v = ; v = staticinvoke (1, v); = v; v = newarray (org.apache.nifi.components.PropertyDescriptor)[38]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = ; v[5] = v; v = ; v[6] = v; v = ; v[7] = v; v = ; v[8] = v; v = ; v[9] = v; v = ; v[10] = v; v = ; v[11] = v; v = ; v[12] = v; v = ; v[13] = v; v = ; v[14] = v; v = ; v[15] = v; v = ; v[16] = v; v = ; v[17] = v; v = ; v[18] = v; v = ; v[19] = v; v = ; v[20] = v; v = ; v[21] = v; v = ; v[22] = v; v = ; v[23] = v; v = ; v[24] = v; v = ; v[25] = v; v = ; v[26] = v; v = ; v[27] = v; v = ; v[28] = v; v = ; v[29] = v; v = ; v[30] = v; v = ; v[31] = v; v = ; v[32] = v; v = ; v[33] = v; v = ; v[34] = v; v = ; v[35] = v; v = ; v[36] = v; v = ; v[37] = v; v = staticinvoke (v); v = staticinvoke (v); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Original"); v = virtualinvoke v.("Request FlowFiles transferred when receiving HTTP responses with a status code between 200 and 299."); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Response"); v = virtualinvoke v.("Response FlowFiles transferred when receiving HTTP responses with a status code between 200 and 299."); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Retry"); v = virtualinvoke v.("Request FlowFiles transferred when receiving HTTP responses with a status code between 500 and 599."); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("No Retry"); v = virtualinvoke v.("Request FlowFiles transferred when receiving HTTP responses with a status code between 400 an 499."); v = virtualinvoke v.(); = v; v = new org.apache.nifi.processor.Relationship$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Failure"); v = virtualinvoke v.("Request FlowFiles transferred when receiving socket communication errors."); v = virtualinvoke v.(); = v; v = new java.util.HashSet; v = newarray (org.apache.nifi.processor.Relationship)[5]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (v); = v; v = ; v = staticinvoke ("EEE, dd MMM yyyy HH:mm:ss \'GMT\'", v); = v; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/InvokeHTTP;"); = v; return; } }