class org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler extends org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler
{
private final org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder builder;
private final boolean isEpochBump;
final org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0;
private void <init>(org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager, org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder, boolean)
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v;
org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler;
v := @parameter: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager;
v := @parameter: org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder;
v := @parameter: boolean;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0> = v;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler: void <init>(org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager,java.lang.String)>(v, "InitProducerId");
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder builder> = v;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: boolean isEpochBump> = v;
return;
}
org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder requestBuilder()
{
org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.common.requests.InitProducerIdRequest$Builder builder>;
return v;
}
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority priority()
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority v;
boolean v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: boolean isEpochBump>;
if v == 0 goto label;
v = <org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority EPOCH_BUMP>;
goto label;
label:
v = <org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$Priority INIT_PRODUCER_ID>;
label:
return v;
}
org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType coordinatorType()
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v;
org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: boolean isTransactional()>();
if v == 0 goto label;
v = <org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType TRANSACTION>;
return v;
label:
return null;
}
public void handleResponse(org.apache.kafkaesqueesque.common.requests.AbstractResponse)
{
org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult v;
long v;
short v;
org.apache.kafkaesqueesque.common.protocol.Errors v, v, v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
org.apache.kafkaesqueesque.common.utils.ProducerIdAndEpoch v;
boolean v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v;
org.apache.kafkaesqueesque.common.errors.ApiException v;
org.apache.kafkaesqueesque.common.message.InitProducerIdResponseData v, v;
org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$State v;
org.apache.kafkaesqueesque.common.KafkaException v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractResponse;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.InitProducerIdResponse: org.apache.kafkaesqueesque.common.protocol.Errors error()>();
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NONE>;
if v != v goto label;
v = new org.apache.kafkaesqueesque.common.utils.ProducerIdAndEpoch;
v = v.<org.apache.kafkaesqueesque.common.requests.InitProducerIdResponse: org.apache.kafkaesqueesque.common.message.InitProducerIdResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.InitProducerIdResponseData: long producerId()>();
v = v.<org.apache.kafkaesqueesque.common.requests.InitProducerIdResponse: org.apache.kafkaesqueesque.common.message.InitProducerIdResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.InitProducerIdResponseData: short producerEpoch()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.ProducerIdAndEpoch: void <init>(long,short)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: void setProducerIdAndEpoch(org.apache.kafkaesqueesque.common.utils.ProducerIdAndEpoch)>(v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = <org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$State: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$State READY>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: void transitionTo(org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$State)>(v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: java.lang.RuntimeException lastError> = null;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: boolean isEpochBump>;
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: void resetSequenceNumbers()>();
label:
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult result>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionalRequestResult: void done()>();
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NOT_COORDINATOR>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v != v goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = <org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType TRANSACTION>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: java.lang.String transactionalId>;
specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager: void lookupCoordinator(org.apache.kafkaesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: void reenqueue()>();
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors CONCURRENT_TRANSACTIONS>;
if v != v goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: void reenqueue()>();
goto label;
label:
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors TRANSACTIONAL_ID_AUTHORIZATION_FAILED>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors CLUSTER_AUTHORIZATION_FAILED>;
if v != v goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: void fatalError(java.lang.RuntimeException)>(v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.KafkaException;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: java.lang.String message()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Unexpected error in InitProducerIdResponse; \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.TransactionManager$InitProducerIdHandler: void fatalError(java.lang.RuntimeException)>(v);
label:
return;
}
}