public class org.apache.nifi.processors.standard.PostHTTP extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String CONTENT_TYPE_HEADER;
public static final java.lang.String ACCEPT;
public static final java.lang.String ACCEPT_ENCODING;
public static final java.lang.String DEFAULT_CONTENT_TYPE;
public static final java.lang.String FLOWFILE_CONFIRMATION_HEADER;
public static final java.lang.String LOCATION_HEADER_NAME;
public static final java.lang.String LOCATION_URI_INTENT_NAME;
public static final java.lang.String LOCATION_URI_INTENT_VALUE;
public static final java.lang.String GZIPPED_HEADER;
public static final java.lang.String CONTENT_ENCODING_HEADER;
public static final java.lang.String CONTENT_ENCODING_GZIP_VALUE;
public static final java.lang.String PROTOCOL_VERSION_HEADER;
public static final java.lang.String TRANSACTION_ID_HEADER;
public static final java.lang.String PROTOCOL_VERSION;
public static final java.lang.String REMOTE_DN;
private static final java.lang.String FLOW_FILE_CONNECTION_LOG;
public static final org.apache.nifi.components.PropertyDescriptor URL;
public static final org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE;
public static final org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT;
public static final org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT;
public static final org.apache.nifi.components.PropertyDescriptor USERNAME;
public static final org.apache.nifi.components.PropertyDescriptor PASSWORD;
public static final org.apache.nifi.components.PropertyDescriptor USER_AGENT;
public static final org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_AS_HEADERS_REGEX;
public static final org.apache.nifi.components.PropertyDescriptor MAX_DATA_RATE;
public static final org.apache.nifi.components.PropertyDescriptor MAX_BATCH_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING;
public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE;
public static final org.apache.nifi.components.PropertyDescriptor CONTENT_TYPE;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private java.util.Set relationships;
private java.util.List properties;
private final java.util.concurrent.atomic.AtomicReference throttlerRef;
private final java.util.concurrent.ConcurrentMap destinationAcceptsMap;
private volatile org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager;
private volatile org.apache.http.impl.client.CloseableHttpClient client;
private volatile org.apache.http.client.config.RequestConfig requestConfig;
private volatile java.security.Principal principal;
public void <init>()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.nifi.processors.standard.PostHTTP v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.atomic.AtomicReference throttlerRef> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.ConcurrentMap destinationAcceptsMap> = v;
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v;
java.util.Set v;
java.util.List v;
org.apache.nifi.processors.standard.PostHTTP v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.PostHTTP: java.util.Set relationships> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor URL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_BATCH_SIZE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_DATA_RATE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USERNAME>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_AS_HEADERS_REGEX>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USER_AGENT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.HTTPUtils: org.apache.nifi.components.PropertyDescriptor PROXY_CONFIGURATION_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.HTTPUtils: org.apache.nifi.components.PropertyDescriptor PROXY_HOST>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.util.HTTPUtils: org.apache.nifi.components.PropertyDescriptor PROXY_PORT>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONTENT_TYPE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.PostHTTP: java.util.List properties> = v;
return;
}
public java.util.Set getRelationships()
{
org.apache.nifi.processors.standard.PostHTTP v;
java.util.Set v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.Set relationships>;
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.processors.standard.PostHTTP v;
java.util.List v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.List properties>;
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.PostHTTP v;
org.apache.nifi.components.ValidationContext v;
java.util.ArrayList v;
int v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v;
org.apache.nifi.components.ValidationResult v, v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor URL>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("https");
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
if v != null goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("URL is set to HTTPS protocol but no SSLContext has been specified");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>("SSL Context");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
label:
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v != 0 goto label;
if v != 0 goto label;
if v != 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("if compression level is 0 and not sending as a FlowFile, then the \'\u0001\' property must be set");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
label:
staticinvoke <org.apache.nifi.processors.standard.util.HTTPUtils: void validateProxyProperties(org.apache.nifi.components.ValidationContext,java.util.Collection)>(v, v);
return v;
}
public void onStopped()
{
org.apache.http.impl.client.CloseableHttpClient v;
java.io.IOException v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
java.util.concurrent.ConcurrentMap v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.nifi.processors.standard.PostHTTP v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.ConcurrentMap destinationAcceptsMap>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: void clear()>();
label:
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void shutdown()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.client.CloseableHttpClient client>;
virtualinvoke v.<org.apache.http.impl.client.CloseableHttpClient: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("Could not properly shutdown connections", v);
label:
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.atomic.AtomicReference throttlerRef>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
return;
catch java.io.IOException from label to label with label;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext)
{
javax.net.ssl.SSLContext v;
org.apache.http.config.SocketConfig v;
org.apache.http.client.config.RequestConfig v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v;
java.net.InetAddress v;
org.apache.http.config.Registry v;
java.lang.Long v, v, v, v;
org.apache.http.config.SocketConfig$Builder v;
java.lang.Exception v;
org.apache.nifi.controller.ControllerService v;
org.apache.nifi.processors.standard.PostHTTP v;
org.apache.nifi.processor.DataUnit v;
org.apache.http.config.RegistryBuilder v, v, v;
java.lang.Double v;
org.apache.nifi.stream.io.LeakyBucketStreamThrottler v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processors.standard.PostHTTP$1 v;
java.net.UnknownHostException v;
org.apache.http.auth.AuthScope v;
org.apache.http.impl.client.HttpClientBuilder v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v;
org.apache.http.impl.client.BasicCredentialsProvider v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v, v, v, v, v, v, v;
org.apache.http.conn.ssl.SSLConnectionSocketFactory v;
org.apache.http.client.config.RequestConfig$Builder v;
javax.security.auth.x.X500Principal v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processor.exception.ProcessException v;
org.apache.http.conn.socket.PlainConnectionSocketFactory v;
int v, v, v, v, v, v, v;
org.apache.http.client.HttpRequestRetryHandler v;
org.apache.http.impl.client.CloseableHttpClient v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v, v, v;
org.apache.http.auth.UsernamePasswordCredentials v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_DATA_RATE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.atomic.AtomicReference throttlerRef>;
if v != null goto label;
v = null;
goto label;
label:
v = new org.apache.nifi.stream.io.LeakyBucketStreamThrottler;
v = v;
v = virtualinvoke v.<java.lang.Double: int intValue()>();
specialinvoke v.<org.apache.nifi.stream.io.LeakyBucketStreamThrottler: void <init>(int)>(v);
label:
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = "unknown";
label:
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLocalHost()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getCanonicalHostName()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = new javax.security.auth.x.X500Principal;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("CN=\u, OU=unknown, O=unknown, C=unknown");
specialinvoke v.<javax.security.auth.x.X500Principal: void <init>(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.PostHTTP: java.security.Principal principal> = v;
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/ssl/SSLContextService;");
if v != null goto label;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>()>();
v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: javax.net.ssl.SSLContext createContext()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = new org.apache.http.conn.ssl.SSLConnectionSocketFactory;
specialinvoke v.<org.apache.http.conn.ssl.SSLConnectionSocketFactory: void <init>(javax.net.ssl.SSLContext)>(v);
v = staticinvoke <org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder create()>();
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("https", v);
v = staticinvoke <org.apache.http.conn.socket.PlainConnectionSocketFactory: org.apache.http.conn.socket.PlainConnectionSocketFactory getSocketFactory()>();
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("http", v);
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.Registry build()>();
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry)>(v);
v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager> = v;
label:
v = staticinvoke <org.apache.http.config.SocketConfig: org.apache.http.config.SocketConfig$Builder custom()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: int intValue()>();
virtualinvoke v.<org.apache.http.config.SocketConfig$Builder: org.apache.http.config.SocketConfig$Builder setSoTimeout(int)>(v);
v = virtualinvoke v.<org.apache.http.config.SocketConfig$Builder: org.apache.http.config.SocketConfig build()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void setDefaultSocketConfig(org.apache.http.config.SocketConfig)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: int getMaxConcurrentTasks()>();
v = v + 1;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void setDefaultMaxPerRoute(int)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void setMaxTotal(int)>(1);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void setValidateAfterInactivity(int)>(30000);
v = staticinvoke <org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder create()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder setConnectionManager(org.apache.http.conn.HttpClientConnectionManager)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USER_AGENT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder setUserAgent(java.lang.String)>(v);
v = new org.apache.nifi.processors.standard.PostHTTP$1;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$1: void <init>(org.apache.nifi.processors.standard.PostHTTP)>(v);
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder addInterceptorFirst(org.apache.http.HttpResponseInterceptor)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.PostHTTP$lambda_onScheduled_0__168: org.apache.http.client.HttpRequestRetryHandler bootstrap$(org.apache.nifi.processors.standard.PostHTTP)>(v);
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder setRetryHandler(org.apache.http.client.HttpRequestRetryHandler)>(v);
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder disableContentCompression()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USERNAME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = new org.apache.http.impl.client.BasicCredentialsProvider;
specialinvoke v.<org.apache.http.impl.client.BasicCredentialsProvider: void <init>()>();
virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.HttpClientBuilder setDefaultCredentialsProvider(org.apache.http.client.CredentialsProvider)>(v);
if v == null goto label;
v = <org.apache.http.auth.AuthScope: org.apache.http.auth.AuthScope ANY>;
v = new org.apache.http.auth.UsernamePasswordCredentials;
specialinvoke v.<org.apache.http.auth.UsernamePasswordCredentials: void <init>(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.http.client.CredentialsProvider: void setCredentials(org.apache.http.auth.AuthScope,org.apache.http.auth.Credentials)>(v, v);
label:
staticinvoke <org.apache.nifi.processors.standard.util.HTTPUtils: void setProxy(org.apache.nifi.processor.ProcessContext,org.apache.http.impl.client.HttpClientBuilder,org.apache.http.client.CredentialsProvider)>(v, v, v);
v = virtualinvoke v.<org.apache.http.impl.client.HttpClientBuilder: org.apache.http.impl.client.CloseableHttpClient build()>();
v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.client.CloseableHttpClient client> = v;
v = staticinvoke <org.apache.http.client.config.RequestConfig: org.apache.http.client.config.RequestConfig$Builder custom()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: int intValue()>();
virtualinvoke v.<org.apache.http.client.config.RequestConfig$Builder: org.apache.http.client.config.RequestConfig$Builder setConnectionRequestTimeout(int)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: int intValue()>();
virtualinvoke v.<org.apache.http.client.config.RequestConfig$Builder: org.apache.http.client.config.RequestConfig$Builder setConnectTimeout(int)>(v);
virtualinvoke v.<org.apache.http.client.config.RequestConfig$Builder: org.apache.http.client.config.RequestConfig$Builder setRedirectsEnabled(boolean)>(0);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Long asTimePeriod(java.util.concurrent.TimeUnit)>(v);
v = virtualinvoke v.<java.lang.Long: int intValue()>();
virtualinvoke v.<org.apache.http.client.config.RequestConfig$Builder: org.apache.http.client.config.RequestConfig$Builder setSocketTimeout(int)>(v);
v = virtualinvoke v.<org.apache.http.client.config.RequestConfig$Builder: org.apache.http.client.config.RequestConfig build()>();
v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.client.config.RequestConfig requestConfig> = v;
return;
catch java.net.UnknownHostException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private java.lang.String getBaseUrl(java.lang.String)
{
int v;
org.apache.nifi.processors.standard.PostHTTP v;
java.lang.String v, v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String,int)>("/", 9);
if v >= 0 goto label;
return v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession)
{
java.lang.Integer v, v, v, v, v, v;
java.util.Map v;
org.apache.nifi.processors.standard.PostHTTP v;
org.apache.nifi.util.StopWatch v;
java.lang.Object[] v, v, v, v, v, v, v, v, v, v, v;
long v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v;
java.io.IOException v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.http.Header v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v;
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v, v, v;
org.apache.http.HttpEntity v, v, v, v, v, v, v;
java.util.UUID v;
java.util.concurrent.ConcurrentMap v, v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v, v;
org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.http.client.methods.HttpPost v;
org.apache.http.client.config.RequestConfig v, v;
org.apache.http.StatusLine v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v;
java.util.regex.Matcher v;
org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts v;
java.util.Set v;
org.apache.nifi.processor.DataUnit v;
java.lang.Throwable v, v, v;
java.lang.Double v;
java.util.ArrayList v;
org.apache.nifi.provenance.ProvenanceReporter 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;
org.apache.nifi.processors.standard.PostHTTP$2 v;
org.apache.nifi.processors.standard.PostHTTP$3 v;
org.apache.nifi.processors.standard.PostHTTP$4 v;
java.net.URL v;
org.apache.http.client.protocol.HttpClientContext v;
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, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v, v, v, v, v, v;
java.util.List v;
java.security.Principal v;
java.util.regex.Pattern v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.http.client.methods.HttpDelete v;
org.apache.http.client.methods.CloseableHttpResponse v, v;
org.apache.http.impl.client.CloseableHttpClient v, v;
java.util.Iterator v, v, v, v, v, v, v, v, v, v;
java.net.MalformedURLException v;
org.apache.nifi.processor.ProcessContext v;
java.util.concurrent.TimeUnit v, v, v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor URL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
label:
v = new java.net.URL;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("After substituting attribute values for {}, URL is {}; this is not a valid URL, so routing to failure", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.atomic.AtomicReference throttlerRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_BATCH_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = new java.util.concurrent.atomic.AtomicLong;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(v);
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = staticinvoke <org.apache.http.client.protocol.HttpClientContext: org.apache.http.client.protocol.HttpClientContext create()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.security.Principal principal>;
virtualinvoke v.<org.apache.http.client.protocol.HttpClientContext: void setUserToken(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP: java.lang.String getBaseUrl(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.ConcurrentMap destinationAcceptsMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts getDestinationAcceptance(boolean,java.lang.String,java.lang.String,org.apache.http.protocol.HttpContext)>(v, v, v, v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: java.util.concurrent.ConcurrentMap destinationAcceptsMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if null != v goto label;
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: int getMaxTotal()>();
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.conn.PoolingHttpClientConnectionManager connManager>;
v = virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: int getDefaultMaxPerRoute()>();
v = v + v;
virtualinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void setMaxTotal(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Unable to communicate with destination {} to determine whether or not it can accept flowfiles/gzip; routing {} to failure", v);
return;
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isFlowFileV3Accepted()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isFlowFileV2Accepted()>();
if v == 0 goto label;
label:
v = new org.apache.nifi.processors.standard.PostHTTP$2;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$2: void <init>(org.apache.nifi.processors.standard.PostHTTP,java.util.concurrent.atomic.AtomicLong,java.lang.Double,org.apache.nifi.processor.ProcessContext,java.lang.String)>(v, v, v, v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.util.List get(org.apache.nifi.processor.FlowFileFilter)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
v = new org.apache.http.client.methods.HttpPost;
specialinvoke v.<org.apache.http.client.methods.HttpPost: void <init>(java.lang.String)>(v);
v = v;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: java.lang.Integer getProtocolVersion()>();
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = new org.apache.nifi.processors.standard.PostHTTP$4;
v = new org.apache.nifi.processors.standard.PostHTTP$3;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$3: void <init>(org.apache.nifi.processors.standard.PostHTTP,org.apache.nifi.stream.io.StreamThrottler,int,org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts,boolean,java.util.List,org.apache.nifi.processor.ProcessSession,boolean)>(v, v, v, v, v, v, v, v);
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$4: void <init>(org.apache.nifi.processors.standard.PostHTTP,org.apache.http.entity.ContentProducer,int,boolean,org.apache.nifi.processor.ProcessContext,java.util.List)>(v, v, v, v, v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v > 10 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u FlowFiles");
label:
v = v;
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.http.entity.EntityTemplate: void setChunked(boolean)>(v);
label:
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setEntity(org.apache.http.HttpEntity)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.client.config.RequestConfig requestConfig>;
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setConfig(org.apache.http.client.config.RequestConfig)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isFlowFileV3Accepted()>();
if v == 0 goto label;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_3>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isFlowFileV2Accepted()>();
if v == 0 goto label;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_2>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isFlowFileV1Accepted()>();
if v == 0 goto label;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_1>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
goto label;
label:
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Cannot send {} to {} because the destination does not accept FlowFiles and this processor is configured to deliver FlowFiles; routing to failure", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
label:
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONTENT_TYPE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isBlank(java.lang.String)>(v);
if v == 0 goto label;
v = "application/octet-stream";
goto label;
label:
v = v;
label:
v = v;
label:
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_AS_HEADERS_REGEX>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
if v == null goto label;
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 1 goto label;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.util.Map getAttributes()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("Content-Type", v);
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("x-prefer-acknowledge-uri", "true");
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("x-nifi-transfer-protocol-version", "3");
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("x-nifi-transaction-id", v);
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: boolean isGzipAccepted()>();
if v == 0 goto label;
if v == 0 goto label;
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("flowfile-gzipped", "true");
goto label;
label:
virtualinvoke v.<org.apache.http.client.methods.HttpPost: void setHeader(java.lang.String,java.lang.String)>("Content-Encoding", "gzip");
label:
v = null;
label:
v = new org.apache.nifi.util.StopWatch;
specialinvoke v.<org.apache.nifi.util.StopWatch: void <init>(boolean)>(1);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.client.CloseableHttpClient client>;
v = virtualinvoke v.<org.apache.http.impl.client.CloseableHttpClient: org.apache.http.client.methods.CloseableHttpResponse execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.protocol.HttpContext)>(v, v);
virtualinvoke v.<org.apache.nifi.util.StopWatch: void stop()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: java.lang.String calculateDataRate(long)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.nifi.util.StopWatch: long getDuration(java.util.concurrent.TimeUnit)>(v);
label:
if v == null goto label;
label:
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to Post {} transferring to failure", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
if v == null goto label;
label:
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
label:
v := @caughtexception;
if v == null goto label;
label:
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
throw v;
label:
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: int getStatusCode()>();
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: java.lang.String getReasonPhrase()>();
v = null;
if v != 303 goto label;
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.Header getFirstHeader(java.lang.String)>("x-location-uri-intent");
if v == null goto label;
v = "flowfile-hold";
v = interfaceinvoke v.<org.apache.http.Header: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.http.client.methods.CloseableHttpResponse: org.apache.http.Header getFirstHeader(java.lang.String)>("Location");
if v == null goto label;
v = interfaceinvoke v.<org.apache.http.Header: java.lang.String getValue()>();
label:
if v != null goto label;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to Post {} to {}: sent content and received status code {}:{} but no Hold URI", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
label:
if v != null goto label;
if v != 503 goto label;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to Post {} to {}: response code was {}:{}", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
label:
if v < 300 goto label;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to Post {} to {}: response code was {}:{}", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
label:
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = staticinvoke <org.apache.nifi.util.FormatUtils: java.lang.String formatMinutesSeconds(long,java.util.concurrent.TimeUnit)>(v, v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Successfully Posted {} to {} in {} at a rate of {}", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = virtualinvoke v.<org.apache.http.client.protocol.HttpClientContext: java.lang.Object getAttribute(java.lang.String)>("remote.dn");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Remote DN=\u0001");
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void send(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,long,boolean)>(v, v, v, v, 1);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
return;
label:
v = v;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/contentListener");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(16);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001");
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String,int)>("/", 8);
if v >= 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001");
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("http");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("/");
if v == 0 goto label;
v = "";
goto label;
label:
v = "/";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001\u0001");
label:
v = new org.apache.http.client.methods.HttpDelete;
specialinvoke v.<org.apache.http.client.methods.HttpDelete: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.http.client.methods.HttpDelete: void setHeader(java.lang.String,java.lang.String)>("x-nifi-transaction-id", v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.client.config.RequestConfig requestConfig>;
virtualinvoke v.<org.apache.http.client.methods.HttpDelete: void setConfig(org.apache.http.client.config.RequestConfig)>(v);
v = null;
label:
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.client.CloseableHttpClient client>;
v = virtualinvoke v.<org.apache.http.impl.client.CloseableHttpClient: org.apache.http.client.methods.CloseableHttpResponse execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.protocol.HttpContext)>(v, v);
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: int getStatusCode()>();
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: java.lang.String getReasonPhrase()>();
if v < 300 goto label;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to delete Hold that destination placed on {}: got response code {}:{}; routing to failure", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
label:
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = staticinvoke <org.apache.nifi.util.FormatUtils: java.lang.String formatMinutesSeconds(long,java.util.concurrent.TimeUnit)>(v, v);
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Successfully Posted {} to {} in {} at a rate of {}", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = virtualinvoke v.<org.apache.http.client.protocol.HttpClientContext: java.lang.Object getAttribute(java.lang.String)>("remote.dn");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Remote DN=\u0001");
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void send(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,long,boolean)>(v, v, v, v, 1);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("Failed to delete Hold that destination placed on, routing to failure", v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
if null == v goto label;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
if null == v goto label;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.HttpEntity getEntity()>();
staticinvoke <org.apache.http.util.EntityUtils: void consume(org.apache.http.HttpEntity)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
throw v;
label:
return;
catch java.net.MalformedURLException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch org.apache.nifi.processor.exception.ProcessException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
private org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts getDestinationAcceptance(boolean, java.lang.String, java.lang.String, org.apache.http.protocol.HttpContext) throws java.io.IOException
{
org.apache.http.client.config.RequestConfig v;
java.lang.Integer v;
org.apache.http.StatusLine v, v;
javax.ws.rs.core.Response$Status v, v;
org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts v, v, v;
org.apache.nifi.processors.standard.PostHTTP v;
java.lang.Object[] v, v, v;
org.apache.http.client.methods.HttpHead v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.NumberFormatException v;
org.apache.http.protocol.HttpContext v;
org.apache.http.Header v, v, v;
boolean v, v, v, v, v, v, v, v, v;
org.apache.http.Header[] v, v;
java.lang.String[] v, v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v, v, v;
org.apache.http.client.methods.CloseableHttpResponse v;
int v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType v, v, v, v, v;
org.apache.http.impl.client.CloseableHttpClient v;
v := @this: org.apache.nifi.processors.standard.PostHTTP;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.http.protocol.HttpContext;
v = new org.apache.http.client.methods.HttpHead;
specialinvoke v.<org.apache.http.client.methods.HttpHead: void <init>(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.client.config.RequestConfig requestConfig>;
virtualinvoke v.<org.apache.http.client.methods.HttpHead: void setConfig(org.apache.http.client.config.RequestConfig)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.http.client.methods.HttpHead: void addHeader(java.lang.String,java.lang.String)>("x-nifi-transaction-id", v);
label:
v = v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.http.impl.client.CloseableHttpClient client>;
v = virtualinvoke v.<org.apache.http.impl.client.CloseableHttpClient: org.apache.http.client.methods.CloseableHttpResponse execute(org.apache.http.client.methods.HttpUriRequest,org.apache.http.protocol.HttpContext)>(v, v);
v = 0;
v = 0;
v = 0;
v = null;
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: int getStatusCode()>();
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status METHOD_NOT_ALLOWED>;
v = virtualinvoke v.<javax.ws.rs.core.Response$Status: int getStatusCode()>();
if v != v goto label;
v = new org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: void <init>(boolean,boolean,boolean,boolean,java.lang.Integer)>(0, 0, v, 0, null);
return v;
label:
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status OK>;
v = virtualinvoke v.<javax.ws.rs.core.Response$Status: int getStatusCode()>();
if v != v goto label;
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.Header[] getHeaders(java.lang.String)>("Accept");
if v == 0 goto label;
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<org.apache.http.Header: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_3>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_2>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.Header getFirstHeader(java.lang.String)>("x-nifi-transfer-protocol-version");
if v == null goto label;
label:
v = interfaceinvoke v.<org.apache.http.Header: java.lang.String getValue()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isDebugEnabled()>();
if v == 0 goto label;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_3>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Connection to URI {} will be using Content Type {} if sending data as FlowFile", v);
goto label;
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_2>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Connection to URI {} will be using Content Type {} if sending data as FlowFile", v);
goto label;
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v = <org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType VERSION_1>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.StandardFlowFileMediaType: java.lang.String getMediaType()>();
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("Connection to URI {} will be using Content Type {} if sending data as FlowFile", v);
label:
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.Header[] getHeaders(java.lang.String)>("Accept-Encoding");
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<org.apache.http.Header: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("gzip");
if v == 0 goto label;
v = 1;
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isDebugEnabled()>();
if v == 0 goto label;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Connection to URI \u indicates that inline GZIP compression is supported");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Connection to URI \u indicates that it does NOT support inline GZIP compression");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String)>(v);
label:
v = new org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: void <init>(boolean,boolean,boolean,boolean,java.lang.Integer)>(v, v, v, v, v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.logging.ComponentLog getLogger()>();
v = interfaceinvoke v.<org.apache.http.HttpResponse: org.apache.http.StatusLine getStatusLine()>();
v = interfaceinvoke v.<org.apache.http.StatusLine: java.lang.String getReasonPhrase()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to communicate with destination; when attempting to perform an HTTP HEAD, got unexpected response code of \u0001: \u0001");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
v = new org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts;
specialinvoke v.<org.apache.nifi.processors.standard.PostHTTP$DestinationAccepts: void <init>(boolean,boolean,boolean,boolean,java.lang.Integer)>(0, 0, 0, 0, null);
return v;
catch java.lang.NumberFormatException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes 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;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
java.util.regex.Pattern v;
java.lang.String[] v, v;
org.apache.nifi.components.Validator 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 = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("URL");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The URL to POST to. The URL may be defined using the Attribute Expression Language. A separate connection pool will be created for each unique host:port combination.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("https?\\://.*");
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createRegexMatchingValidator(java.util.regex.Pattern)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator URL_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor URL> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Send as FlowFile");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If true, will package the FlowFile\'s contents and attributes together and send the FlowFile Package; otherwise, will send only the FlowFile\'s content");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Connection Timeout");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("How long to wait when attempting to connect to the remote server before giving up");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("30 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Data Timeout");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("How long to wait between receiving segments of data from the remote server before giving up and discarding the partial file");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("30 sec");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator TIME_PERIOD_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Username");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Username required to access the URL");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USERNAME> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Password");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Password required to access the URL");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder sensitive(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor PASSWORD> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("User Agent");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("What to report as the User Agent when we connect to the remote server");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = staticinvoke <org.apache.http.util.VersionInfo: java.lang.String getUserAgent(java.lang.String,java.lang.String,java.lang.Class)>("Apache-HttpClient", "org.apache.http.client", class "Lorg/apache/http/impl/client/HttpClientBuilder;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor USER_AGENT> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Compression Level");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Determines the GZIP Compression Level to use when sending the file; the value must be in the range of 0-9. A value of 0 indicates that the file will not be GZIP\'ed");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createLongValidator(long,long,boolean)>(0L, 9L, 1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("0");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor COMPRESSION_LEVEL> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Attributes to Send as HTTP Headers (Regex)");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the Regular Expression that determines the names of FlowFile attributes that should be sent as HTTP Headers");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator REGULAR_EXPRESSION_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_AS_HEADERS_REGEX> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Max Data to Post per Second");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum amount of data to send per second; this allows the bandwidth to be throttled to a specified data rate; if not specified, the data rate is not throttled");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator DATA_SIZE_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_DATA_RATE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Max Batch Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If the Send as FlowFile property is true, specifies the max data size for a batch of FlowFiles to send in a single HTTP POST. If not specified, each FlowFile will be sent separately. If the Send as FlowFile property is false, this property is ignored");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator DATA_SIZE_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("100 MB");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor MAX_BATCH_SIZE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Use Chunked Encoding");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies whether or not to use Chunked Encoding to send the data. This property is ignored in the event the contents are compressed or sent as FlowFiles.");
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CHUNKED_ENCODING> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("SSL Context Service");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Controller Service to use in order to obtain an SSL Context");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/ssl/SSLContextService;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Content-Type");
v = <org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor SEND_AS_FLOWFILE>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The Content-Type to specify for the content of the FlowFile being POSTed if \u is false. In the case of an empty value after evaluating an expression language expression, Content-Type defaults to application/octet-stream");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("${\u0001}");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.components.PropertyDescriptor CONTENT_TYPE> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Files that are successfully send will be transferred to success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Files that fail to send will transferred to failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.PostHTTP: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}