class org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap extends org.apache.nifi.controller.AbstractControllerService implements org.apache.nifi.http.HttpContextMap
{
private final java.lang.String id;
private final java.util.concurrent.atomic.AtomicInteger completedCount;
private final java.io.ByteArrayOutputStream outputStream;
private final java.util.concurrent.ConcurrentMap headersSent;
private final java.lang.Exception responseException;
private final java.lang.RuntimeException completeException;
private volatile int statusCode;
private final java.util.List headersWithNoValue;
public void <init>(java.lang.String, java.lang.Exception, java.lang.RuntimeException)
{
java.io.ByteArrayOutputStream v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.RuntimeException v;
java.lang.Exception v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
java.lang.String v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Exception;
v := @parameter: java.lang.RuntimeException;
specialinvoke v.<org.apache.nifi.controller.AbstractControllerService: void <init>()>();
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.atomic.AtomicInteger completedCount> = v;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.io.ByteArrayOutputStream outputStream> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.ConcurrentMap headersSent> = v;
v = (int) -1;
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: int statusCode> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.List headersWithNoValue> = v;
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.String id> = v;
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.Exception responseException> = v;
v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.RuntimeException completeException> = v;
return;
}
public boolean register(java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, javax.servlet.AsyncContext)
{
javax.servlet.AsyncContext v;
javax.servlet.http.HttpServletRequest v;
javax.servlet.http.HttpServletResponse v;
java.lang.String v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v := @parameter: javax.servlet.AsyncContext;
return 1;
}
public javax.servlet.http.HttpServletResponse getResponse(java.lang.String)
{
org.mockito.stubbing.Stubber v, v;
org.mockito.stubbing.Answer v, v;
javax.servlet.ServletOutputStream v, v;
int v;
java.lang.String v, v, v, v, v;
boolean v;
org.mockito.stubbing.OngoingStubbing v, v;
java.lang.Exception v, v, v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
java.lang.Throwable[] v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap$1 v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.String id>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.String id>;
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[])>("attempting to respond to wrong request; should have been \u but was \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Ljavax/servlet/http/HttpServletResponse;");
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.Exception responseException>;
if v != null goto label;
v = interfaceinvoke v.<javax.servlet.http.HttpServletResponse: javax.servlet.ServletOutputStream getOutputStream()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = new org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap$1;
specialinvoke v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap$1: void <init>(org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap)>(v);
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletResponse: javax.servlet.ServletOutputStream getOutputStream()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.Exception responseException>;
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap$lambda_getResponse_0__96: org.mockito.stubbing.Answer bootstrap$(org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object any(java.lang.Class)>(class "Ljava/lang/String;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object any(java.lang.Class)>(class "Ljava/lang/String;");
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void setHeader(java.lang.String,java.lang.String)>(v, v);
v = staticinvoke <org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap$lambda_getResponse_1__97: org.mockito.stubbing.Answer bootstrap$(org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: int anyInt()>();
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void setStatus(int)>(v);
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.lang.Exception: void printStackTrace()>();
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
return null;
catch java.lang.Exception from label to label with label;
}
public void complete(java.lang.String)
{
java.lang.RuntimeException v, v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
java.util.concurrent.atomic.AtomicInteger v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.String id>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.String id>;
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[])>("attempting to respond to wrong request; should have been \u but was \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>(v);
label:
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.RuntimeException completeException>;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.lang.RuntimeException completeException>;
throw v;
label:
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.atomic.AtomicInteger completedCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
return;
}
public int getCompletionCount()
{
int v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v = v.<org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap: java.util.concurrent.atomic.AtomicInteger completedCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public long getRequestTimeout(java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v, v;
long v;
org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap v;
v := @this: org.apache.nifi.processors.standard.TestHandleHttpResponse$MockHttpContextMap;
v := @parameter: java.util.concurrent.TimeUnit;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long convert(long,java.util.concurrent.TimeUnit)>(30000L, v);
return v;
}
}