class org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest extends java.lang.Object
{
final org.apache.kafkaesqueesque.common.requests.RequestHeader header;
final java.lang.String destination;
final org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback;
final boolean expectResponse;
final org.apache.kafkaesqueesque.common.requests.AbstractRequest request;
final boolean isInternalRequest;
final org.apache.kafkaesqueesque.common.network.Send send;
final long sendTimeMs;
final long createdTimeMs;
final long requestTimeoutMs;
public void <init>(org.apache.kafkaesqueesque.clients.ClientRequest, org.apache.kafkaesqueesque.common.requests.RequestHeader, boolean, org.apache.kafkaesqueesque.common.requests.AbstractRequest, org.apache.kafkaesqueesque.common.network.Send, long)
{
org.apache.kafkaesqueesque.clients.ClientRequest v;
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.AbstractRequest v;
long v, v;
org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
int v;
java.lang.String v;
org.apache.kafkaesqueesque.common.network.Send v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest;
v := @parameter: org.apache.kafkaesqueesque.clients.ClientRequest;
v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestHeader;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractRequest;
v := @parameter: org.apache.kafkaesqueesque.common.network.Send;
v := @parameter: long;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.ClientRequest: int requestTimeoutMs()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.ClientRequest: long createdTimeMs()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.ClientRequest: java.lang.String destination()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.ClientRequest: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.ClientRequest: boolean expectResponse()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: void <init>(org.apache.kafkaesqueesque.common.requests.RequestHeader,int,long,java.lang.String,org.apache.kafkaesqueesque.clients.RequestCompletionHandler,boolean,boolean,org.apache.kafkaesqueesque.common.requests.AbstractRequest,org.apache.kafkaesqueesque.common.network.Send,long)>(v, v, v, v, v, v, v, v, v, v);
return;
}
public void <init>(org.apache.kafkaesqueesque.common.requests.RequestHeader, int, long, java.lang.String, org.apache.kafkaesqueesque.clients.RequestCompletionHandler, boolean, boolean, org.apache.kafkaesqueesque.common.requests.AbstractRequest, org.apache.kafkaesqueesque.common.network.Send, long)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.AbstractRequest v;
long v, v;
org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
int v;
java.lang.String v;
org.apache.kafkaesqueesque.common.network.Send v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest;
v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestHeader;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.clients.RequestCompletionHandler;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractRequest;
v := @parameter: org.apache.kafkaesqueesque.common.network.Send;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.RequestHeader header> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long requestTimeoutMs> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long createdTimeMs> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: java.lang.String destination> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: boolean expectResponse> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: boolean isInternalRequest> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.AbstractRequest request> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.network.Send send> = v;
v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long sendTimeMs> = v;
return;
}
public org.apache.kafkaesqueesque.clients.ClientResponse completed(org.apache.kafkaesqueesque.common.requests.AbstractResponse, long)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
long v, v;
org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractResponse;
v := @parameter: long;
v = new org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: java.lang.String destination>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long createdTimeMs>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.ClientResponse: 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)>(v, v, v, v, v, 0, null, null, v);
return v;
}
public org.apache.kafkaesqueesque.clients.ClientResponse disconnected(long, org.apache.kafkaesqueesque.common.errors.AuthenticationException)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.errors.AuthenticationException v;
long v, v;
org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.ClientResponse v;
v := @this: org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest;
v := @parameter: long;
v := @parameter: org.apache.kafkaesqueesque.common.errors.AuthenticationException;
v = new org.apache.kafkaesqueesque.clients.ClientResponse;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: java.lang.String destination>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long createdTimeMs>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.ClientResponse: 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)>(v, v, v, v, v, 1, null, v, null);
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.AbstractRequest v;
long v, v;
org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest v;
org.apache.kafkaesqueesque.clients.RequestCompletionHandler v;
java.lang.String v, v;
org.apache.kafkaesqueesque.common.network.Send v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: java.lang.String destination>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: boolean expectResponse>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long createdTimeMs>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: long sendTimeMs>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: boolean isInternalRequest>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.requests.AbstractRequest request>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.clients.RequestCompletionHandler callback>;
v = v.<org.apache.kafkaesqueesque.clients.NetworkClient$InFlightRequest: org.apache.kafkaesqueesque.common.network.Send send>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.requests.RequestHeader,java.lang.String,boolean,long,long,boolean,org.apache.kafkaesqueesque.common.requests.AbstractRequest,org.apache.kafkaesqueesque.clients.RequestCompletionHandler,org.apache.kafkaesqueesque.common.network.Send)>(v, v, v, v, 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[])>("InFlightRequest(header=\u, destination=\u, expectResponse=\u, createdTimeMs=\u, sendTimeMs=\u, isInternalRequest=\u, request=\u, callback=\u, send=\u)");
return v;
}
}