class org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion extends java.lang.Object
{
private final long offset;
private final org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata metadata;
private final org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult result;
private final org.apache.kafkaesqueesqueesque.clients.producer.Callback callback;
public void <init>(long, org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata, org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult, org.apache.kafkaesqueesqueesque.clients.producer.Callback)
{
org.apache.kafkaesqueesqueesque.clients.producer.Callback v;
org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult v;
long v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion;
v := @parameter: long;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.Callback;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata metadata> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: long offset> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult result> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.Callback callback> = v;
return;
}
public void complete(java.lang.RuntimeException)
{
org.apache.kafkaesqueesqueesque.clients.producer.Callback v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult v, v;
long v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion;
v := @parameter: java.lang.RuntimeException;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult result>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: long offset>;
goto label;
label:
v = -1L;
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult: void set(long,long,java.lang.RuntimeException)>(v, -1L, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.Callback callback>;
if v == null goto label;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.Callback callback>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata metadata>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.Callback: void onCompletion(org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata,java.lang.Exception)>(v, null);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.Callback callback>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.Callback: void onCompletion(org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata,java.lang.Exception)>(null, v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.MockProducer$Completion: org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult result>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.ProduceRequestResult: void done()>();
return;
}
}