public class org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation extends java.lang.Object implements org.apache.kafkaesque.common.protocol.Message
{
private byte resourceType;
private java.lang.String resourceName;
private byte resourcePatternType;
private java.lang.String principal;
private java.lang.String host;
private byte operation;
private byte permissionType;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.protocol.Readable v;
short v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: void read(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType> = 0;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName> = "";
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = 3;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal> = "";
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host> = "";
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation> = 0;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType> = 0;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
return 2;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
byte v, v, v, v;
java.util.List v, v;
short v, v, v, v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.lang.RuntimeException v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
if v <= 2 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t read version \u of AclCreation");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: byte readByte()>();
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field resourceName was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("string field resourceName had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName> = v;
if v < 1 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: byte readByte()>();
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = 3;
label:
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field principal was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("string field principal had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field host was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("string field host had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: byte readByte()>();
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: byte readByte()>();
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType> = v;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields> = null;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesque.common.protocol.Writable, org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
byte v, v, v, v, v;
org.apache.kafkaesque.common.protocol.Writable v;
java.util.List v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v;
short v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 2 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t write version \u of AclCreation");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByte(byte)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByte(byte)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
if v == 3 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default resourcePatternType at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByte(byte)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByte(byte)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 2 goto label;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
java.util.ArrayList v;
short v;
byte v, v, v, v;
int v;
java.lang.String v, v, v, v;
boolean v, v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.util.Set v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 2 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t read version \u of AclCreation");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields> = null;
if v < 2 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte getByte(java.lang.String)>("resource_type");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("resource_name");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName> = v;
if v < 1 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte getByte(java.lang.String)>("resource_pattern_type");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = 3;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("principal");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("host");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte getByte(java.lang.String)>("operation");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte getByte(java.lang.String)>("permission_type");
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType> = v;
if v < 2 goto label;
v = interfaceinvoke v.<java.util.NavigableMap: boolean isEmpty()>();
if v != 0 goto label;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.NavigableMap: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields> = v;
v = interfaceinvoke v.<java.util.NavigableMap: 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 = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
org.apache.kafkaesque.common.protocol.types.Schema v;
short v;
byte v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.lang.Byte v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.TreeMap v, v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: short;
if v <= 2 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t write version \u of AclCreation");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
if v < 2 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("resource_type", v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("resource_name", v);
if v < 1 goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("resource_pattern_type", v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
if v == 3 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default resourcePatternType at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("principal", v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("host", v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("operation", v);
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("permission_type", v);
if v < 2 goto label;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
short v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
java.lang.RuntimeException v, v, v;
boolean v;
java.util.List v, v, v;
java.nio.charset.Charset v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 2 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Can\'t size version \u of AclCreation");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'resourceName\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = 1 + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = 1 + v;
label:
if v < 1 goto label;
v = v + 1;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'principal\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'host\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v + 1;
v = v + 1;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: 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 = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 2 goto label;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
byte v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
if v == v goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
byte v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
v = v + v;
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
byte v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
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[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
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[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
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[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte,java.lang.String,byte,java.lang.String,java.lang.String,byte,byte)>(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[])>("AclCreation(resourceType=\u, resourceName=\u, resourcePatternType=\u, principal=\u, host=\u, operation=\u, permissionType=\u)");
return v;
}
public byte resourceType()
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType>;
return v;
}
public java.lang.String resourceName()
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName>;
return v;
}
public byte resourcePatternType()
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType>;
return v;
}
public java.lang.String principal()
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal>;
return v;
}
public java.lang.String host()
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host>;
return v;
}
public byte operation()
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation>;
return v;
}
public byte permissionType()
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setResourceType(byte)
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: byte;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourceType> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setResourceName(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String resourceName> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setResourcePatternType(byte)
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: byte;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte resourcePatternType> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setPrincipal(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String principal> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setHost(java.lang.String)
{
java.lang.String v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: java.lang.String host> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setOperation(byte)
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: byte;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte operation> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation setPermissionType(byte)
{
byte v;
org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation v;
v := @this: org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation;
v := @parameter: byte;
v.<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: byte permissionType> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v;
java.lang.Object[] v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[6];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_type", v, "The type of the resource.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_name", v, "The resource name for the ACL.");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal", v, "The principal for the ACL.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("host", v, "The host for the ACL.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("operation", v, "The operation type for the ACL (read, write, etc.).");
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("permission_type", v, "The permission type for the ACL (allow, deny, etc.).");
v[5] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[7];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_type", v, "The type of the resource.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_name", v, "The resource name for the ACL.");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_pattern_type", v, "The pattern type for the ACL.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal", v, "The principal for the ACL.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("host", v, "The host for the ACL.");
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("operation", v, "The operation type for the ACL (read, write, etc.).");
v[5] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("permission_type", v, "The permission type for the ACL (allow, deny, etc.).");
v[6] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[8];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_type", v, "The type of the resource.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_name", v, "The resource name for the ACL.");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("resource_pattern_type", v, "The pattern type for the ACL.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal", v, "The principal for the ACL.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("host", v, "The host for the ACL.");
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("operation", v, "The operation type for the ACL (read, write, etc.).");
v[5] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("permission_type", v, "The permission type for the ACL (allow, deny, etc.).");
v[6] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[7] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[3];
v = <org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
<org.apache.kafkaesque.common.message.CreateAclsRequestData$AclCreation: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}