class org.apache.kafkaesque.clients.admin.KafkaAdminClient$9 extends org.apache.kafkaesque.clients.admin.KafkaAdminClient$Call
{
final java.util.Collection val$unifiedRequestResources;
final org.apache.kafkaesque.clients.admin.DescribeConfigsOptions val$options;
final java.util.Map val$unifiedRequestFutures;
final org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0;
void <init>(org.apache.kafkaesque.clients.admin.KafkaAdminClient, java.lang.String, long, org.apache.kafkaesque.clients.admin.KafkaAdminClient$NodeProvider, java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeConfigsOptions, java.util.Map)
{
org.apache.kafkaesque.clients.admin.KafkaAdminClient v;
java.util.Collection v;
long v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$NodeProvider v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$9 v;
java.util.Map v;
org.apache.kafkaesque.clients.admin.DescribeConfigsOptions v;
java.lang.String v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$9;
v := @parameter: org.apache.kafkaesque.clients.admin.KafkaAdminClient;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: org.apache.kafkaesque.clients.admin.KafkaAdminClient$NodeProvider;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesque.clients.admin.DescribeConfigsOptions;
v := @parameter: java.util.Map;
v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0> = v;
v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: java.util.Collection val$unifiedRequestResources> = v;
v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: org.apache.kafkaesque.clients.admin.DescribeConfigsOptions val$options> = v;
v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: java.util.Map val$unifiedRequestFutures> = v;
specialinvoke v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$Call: void <init>(org.apache.kafkaesque.clients.admin.KafkaAdminClient,java.lang.String,long,org.apache.kafkaesque.clients.admin.KafkaAdminClient$NodeProvider)>(v, v, v, v);
return;
}
org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder createRequest(int)
{
java.util.Collection v;
org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder v, v;
int v;
org.apache.kafkaesque.clients.admin.DescribeConfigsOptions v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$9 v;
boolean v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$9;
v := @parameter: int;
v = new org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: java.util.Collection val$unifiedRequestResources>;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder: void <init>(java.util.Collection)>(v);
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: org.apache.kafkaesque.clients.admin.DescribeConfigsOptions val$options>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.admin.DescribeConfigsOptions: boolean includeSynonyms()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder: org.apache.kafkaesque.common.requests.DescribeConfigsRequest$Builder includeSynonyms(boolean)>(v);
return v;
}
void handleResponse(org.apache.kafkaesque.common.requests.AbstractResponse)
{
org.apache.kafkaesque.common.requests.DescribeConfigsResponse$Config v;
org.apache.kafkaesque.common.errors.UnknownServerException v;
org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigSource v;
org.apache.kafkaesque.common.requests.ApiError v, v;
java.util.Map v;
boolean v, v, v, v, v;
java.util.Collection v;
java.util.Set v;
org.apache.kafkaesque.clients.admin.Config v;
java.util.List v;
org.apache.kafkaesque.clients.admin.ConfigEntry$ConfigSource v;
java.util.ArrayList v;
java.lang.String v, v, v;
java.util.Iterator v, v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient v, v;
org.apache.kafkaesque.common.errors.ApiException v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$9 v;
org.apache.kafkaesque.clients.admin.ConfigEntry v;
java.lang.Object v, v, v, v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$9;
v := @parameter: org.apache.kafkaesque.common.requests.AbstractResponse;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: java.util.Map val$unifiedRequestFutures>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse: org.apache.kafkaesque.common.requests.DescribeConfigsResponse$Config config(org.apache.kafkaesque.common.config.ConfigResource)>(v);
if v != null goto label;
v = new org.apache.kafkaesque.common.errors.UnknownServerException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.common.config.ConfigResource)>(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[])>("Malformed broker response: missing config for \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnknownServerException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$Config: org.apache.kafkaesque.common.requests.ApiError error()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ApiError: boolean isFailure()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$Config: org.apache.kafkaesque.common.requests.ApiError error()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ApiError: org.apache.kafkaesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesque.common.internals.KafkaFutureImpl: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$Config: java.util.Collection entries()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesque.clients.admin.ConfigEntry;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry: java.lang.String name()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry: java.lang.String value()>();
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry: org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigSource source()>();
v = specialinvoke v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.admin.ConfigEntry$ConfigSource configSource(org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigSource)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry: boolean isSensitive()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry: boolean isReadOnly()>();
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = specialinvoke v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: java.util.List configSynonyms(org.apache.kafkaesque.common.requests.DescribeConfigsResponse$ConfigEntry)>(v);
specialinvoke v.<org.apache.kafkaesque.clients.admin.ConfigEntry: void <init>(java.lang.String,java.lang.String,org.apache.kafkaesque.clients.admin.ConfigEntry$ConfigSource,boolean,boolean,java.util.List)>(v, v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.kafkaesque.clients.admin.Config;
specialinvoke v.<org.apache.kafkaesque.clients.admin.Config: void <init>(java.util.Collection)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.internals.KafkaFutureImpl: boolean complete(java.lang.Object)>(v);
goto label;
label:
return;
}
void handleFailure(java.lang.Throwable)
{
java.lang.Throwable v;
java.util.Collection v;
java.util.Map v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$9 v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$9;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$9: java.util.Map val$unifiedRequestFutures>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
staticinvoke <org.apache.kafkaesque.clients.admin.KafkaAdminClient: void completeAllExceptionally(java.util.Collection,java.lang.Throwable)>(v, v);
return;
}
}