class org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler extends java.lang.Object implements org.apache.kafkaesque.clients.RequestCompletionHandler
{
private final org.apache.kafkaesque.clients.consumer.internals.RequestFuture future;
private org.apache.kafkaesque.clients.ClientResponse response;
private java.lang.RuntimeException e;
final org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient this$0;
private void <init>(org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient)
{
org.apache.kafkaesque.clients.consumer.internals.RequestFuture v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler;
v := @parameter: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient;
v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.kafkaesque.clients.consumer.internals.RequestFuture;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future> = v;
return;
}
public void fireCompletion()
{
java.lang.String v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient v;
boolean v;
org.slf4j.Logger v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
org.apache.kafkaesque.clients.ClientResponse v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.AuthenticationException v, v;
org.apache.kafkaesque.common.requests.RequestHeader v;
java.lang.RuntimeException v, v;
org.apache.kafkaesque.common.errors.DisconnectException v;
org.apache.kafkaesque.clients.consumer.internals.RequestFuture v, v, v, v, v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: java.lang.RuntimeException e>;
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: java.lang.RuntimeException e>;
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void raise(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: org.apache.kafkaesque.common.errors.AuthenticationException authenticationException()>();
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: org.apache.kafkaesque.common.errors.AuthenticationException authenticationException()>();
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void raise(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: boolean wasDisconnected()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient this$0>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: org.apache.kafkaesque.common.requests.RequestHeader requestHeader()>();
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: java.lang.String destination()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Cancelled request with header {} due to node {} being disconnected", v, v);
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future>;
v = <org.apache.kafkaesque.common.errors.DisconnectException: org.apache.kafkaesque.common.errors.DisconnectException INSTANCE>;
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void raise(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: org.apache.kafkaesque.common.errors.UnsupportedVersionException versionMismatch()>();
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.ClientResponse: org.apache.kafkaesque.common.errors.UnsupportedVersionException versionMismatch()>();
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void raise(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.RequestFuture future>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response>;
virtualinvoke v.<org.apache.kafkaesque.clients.consumer.internals.RequestFuture: void complete(java.lang.Object)>(v);
label:
return;
}
public void onFailure(java.lang.RuntimeException)
{
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler v;
java.lang.RuntimeException v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler;
v := @parameter: java.lang.RuntimeException;
v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: java.lang.RuntimeException e> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient this$0>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingCompletion>;
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean add(java.lang.Object)>(v);
return;
}
public void onComplete(org.apache.kafkaesque.clients.ClientResponse)
{
org.apache.kafkaesque.clients.ClientResponse v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler v;
org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler;
v := @parameter: org.apache.kafkaesque.clients.ClientResponse;
v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.ClientResponse response> = v;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient this$0>;
v = v.<org.apache.kafkaesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingCompletion>;
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean add(java.lang.Object)>(v);
return;
}
}