public class org.apache.kafkaesqueesque.clients.ClientResponse extends java.lang.Object
{
private final org.apache.kafkaesqueesque.common.requests.RequestHeader requestHeader;
private final org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback;
private final java.lang.String destination;
private final long receivedTimeMs;
private final long latencyMs;
private final boolean disconnected;
private final org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException versionMismatch;
private final org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException;
private final org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody;
public void <init>(org.apache.kafkaesqueesque.common.requests.RequestHeader, org.apache.kafkaesqueesque.clients.RequestCompletionHandler, java.lang.String, long, long, boolean, org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException, org.apache.kafkaesqueesque.common.errors.AuthenticationException, org.apache.kafkaesqueesque.common.requests.AbstractResponse)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.errors.AuthenticationException v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
long v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
java.lang.String v;
boolean v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestHeader;
v := @parameter: org.apache.kafkaesqueesque.clients.RequestCompletionHandler;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException;
v := @parameter: org.apache.kafkaesqueesque.common.errors.AuthenticationException;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractResponse;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.RequestHeader requestHeader> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: java.lang.String destination> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: long receivedTimeMs> = v;
v = v - v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: long latencyMs> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: boolean disconnected> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException versionMismatch> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException> = v;
v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody> = v;
return;
}
public long receivedTimeMs()
{
long v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: long receivedTimeMs>;
return v;
}
public boolean wasDisconnected()
{
boolean v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: boolean disconnected>;
return v;
}
public org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException versionMismatch()
{
org.apache.kafkaesqueesque.clients.ClientResponse v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException versionMismatch>;
return v;
}
public org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException()
{
org.apache.kafkaesqueesque.common.errors.AuthenticationException v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.errors.AuthenticationException authenticationException>;
return v;
}
public org.apache.kafkaesqueesque.common.requests.RequestHeader requestHeader()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.RequestHeader requestHeader>;
return v;
}
public java.lang.String destination()
{
java.lang.String v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: java.lang.String destination>;
return v;
}
public org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody()
{
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody>;
return v;
}
public boolean hasResponse()
{
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
boolean v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long requestLatencyMs()
{
long v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: long latencyMs>;
return v;
}
public void onComplete()
{
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v, v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback>;
interfaceinvoke v.<org.apache.kafkaesqueesque.clients.RequestCompletionHandler: void onComplete(org.apache.kafkaesqueesque.clients.ClientResponse)>(v);
label:
return;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
long v, v;
java.lang.String v;
boolean v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: long receivedTimeMs>;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: long latencyMs>;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: boolean disconnected>;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.RequestHeader requestHeader>;
v = v.<org.apache.kafkaesqueesque.clients.ClientResponse: org.apache.kafkaesqueesque.common.requests.AbstractResponse responseBody>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long,boolean,org.apache.kafkaesqueesque.common.requests.RequestHeader,org.apache.kafkaesqueesque.common.requests.AbstractResponse)>(v, v, 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[])>("ClientResponse(receivedTimeMs=\u, latencyMs=\u, disconnected=\u, requestHeader=\u, responseBody=\u)");
return v;
}
}