public class org.apache.nifi.processors.standard.TestHandleHttpResponse extends java.lang.Object
{
private static final java.lang.String CONTEXT_MAP_ID;
private static final java.lang.String HTTP_REQUEST_ID;
private static final int HTTP_STATUS_CREATED;
private static final java.lang.String FLOW_FILE_CONTENT;
public void <init>()
{
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testEnsureCompleted() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
java.io.ByteArrayOutputStream v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.concurrent.ConcurrentMap v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
int v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
org.apache.nifi.provenance.ProvenanceEventType v, v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
java.util.List v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", null, null);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("my-attr", "${my-attr}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("no-valid-attr", "${no-valid-attr}");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.request.uri", "/test");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.local.name", "server");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.server.port", "8443");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.remote.host", "client");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.subject.dn", "sslDN");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(201);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("status.code", v);
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.provenance.ProvenanceEventType: org.apache.nifi.provenance.ProvenanceEventType SEND>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: org.apache.nifi.provenance.ProvenanceEventType getEventType()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: java.lang.String getTransitUri()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("https://client@server:8443/test", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.io.ByteArrayOutputStream outputStream>;
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TESTING", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.ConcurrentMap headersSent>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>("my-attr");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("hello", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.ConcurrentMap headersSent>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>("no-valid-attr");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int statusCode>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(201, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.List headersWithNoValue>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testRegexHeaders() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.util.TestRunner v;
boolean v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
java.util.List v, v, v, v;
java.io.ByteArrayOutputStream v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
java.util.concurrent.ConcurrentMap v, v;
org.apache.nifi.processor.Relationship v;
int v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.nifi.provenance.ProvenanceEventType v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", null, null);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_AS_HEADERS_REGEX>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "^(my.*)$");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.request.uri", "/test");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.local.name", "server");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.server.port", "8443");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.remote.host", "client");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.subject.dn", "sslDN");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-blank-attr", "");
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(201);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("status.code", v);
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.provenance.ProvenanceEventType: org.apache.nifi.provenance.ProvenanceEventType SEND>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: org.apache.nifi.provenance.ProvenanceEventType getEventType()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: java.lang.String getTransitUri()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("https://client@server:8443/test", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.io.ByteArrayOutputStream outputStream>;
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TESTING", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.ConcurrentMap headersSent>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>("my-attr");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("hello", v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.ConcurrentMap headersSent>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>("my-blank-attr");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int statusCode>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(201, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.List headersWithNoValue>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testResponseFlowFileAccessException() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
org.apache.nifi.processor.exception.FlowFileAccessException v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v = new org.apache.nifi.processor.exception.FlowFileAccessException;
specialinvoke v.<org.apache.nifi.processor.exception.FlowFileAccessException: void <init>(java.lang.String)>("Access Problem");
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", v, null);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("my-attr", "${my-attr}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("no-valid-attr", "${no-valid-attr}");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(201);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("status.code", v);
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
return;
}
public void testResponseProcessException() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.exception.ProcessException v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", v, null);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("my-attr", "${my-attr}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("no-valid-attr", "${no-valid-attr}");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(201);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("status.code", v);
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
return;
}
public void testResponseProcessExceptionThenIllegalStateException() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
java.lang.IllegalStateException v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.exception.ProcessException v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>()>();
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>()>();
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", v, v);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("my-attr", "${my-attr}");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(java.lang.String,java.lang.String)>("no-valid-attr", "${no-valid-attr}");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(201);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("status.code", v);
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
return;
}
public void testStatusCodeEmpty() throws org.apache.nifi.reporting.InitializationException
{
byte[] v;
org.apache.nifi.processors.standard.TestHandleHttpResponse v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/HandleHttpResponse;");
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: void <init>(java.lang.String,java.lang.Exception,java.lang.RuntimeException)>("HTTP-Request-Identifier", null, null);
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
v = <org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.components.PropertyDescriptor STATUS_CODE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${status.code}");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("http.context.identifier", "HTTP-Request-Identifier");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("my-attr", "hello");
v = "TESTING";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.HandleHttpResponse: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = virtualinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int getCompletionCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
return;
}
static void <clinit>()
{
java.lang.Class v;
java.lang.String v;
v = class "Lorg/apache/nifi/processors/standard/TestHandleHttpResponse$MockHttpContextMap;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
<org.apache.nifi.processors.standard.TestHandleHttpResponse: java.lang.String CONTEXT_MAP_ID> = v;
return;
}
}