public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder extends java.lang.Object
{
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion version;
private java.lang.String clientId;
private boolean cleanSession;
private boolean hasUser;
private boolean hasPassword;
private int keepAliveSecs;
private boolean willFlag;
private boolean willRetain;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS willQos;
private java.lang.String willTopic;
private byte[] willMessage;
private java.lang.String username;
private byte[] password;
void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion MQTT_3_1_1>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion version> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS AT_MOST_ONCE>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS willQos> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder protocolVersion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion version> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder clientId(java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: java.lang.String;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String clientId> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder cleanSession(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean cleanSession> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder keepAlive(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: int;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: int keepAliveSecs> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willFlag(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean willFlag> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willQoS(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS willQos> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willTopic(java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: java.lang.String;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String willTopic> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willMessage(java.lang.String)
{
byte[] v;
java.nio.charset.Charset v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: java.lang.String;
if v != null goto label;
v = null;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willMessage(byte[])>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willMessage(byte[])
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: byte[];
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: byte[] willMessage> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder willRetain(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean willRetain> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder hasUser(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasUser> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder hasPassword(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasPassword> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder username(java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: java.lang.String;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasUser> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String username> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder password(java.lang.String)
{
byte[] v;
java.nio.charset.Charset v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: java.lang.String;
if v != null goto label;
v = null;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder password(byte[])>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder password(byte[])
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v := @parameter: byte[];
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasPassword> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: byte[] password> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectMessage build()
{
byte[] v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageType v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttFixedHeader v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectVariableHeader v;
byte v;
int v, v;
java.lang.String v, v, v, v;
boolean v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectPayload v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttFixedHeader;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageType: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageType CONNECT>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS AT_MOST_ONCE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttFixedHeader: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageType,boolean,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS,boolean,int)>(v, 0, v, 0, 0);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectVariableHeader;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion version>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion: java.lang.String protocolName()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion version>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttVersion: byte protocolLevel()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasUser>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean hasPassword>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean willRetain>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS willQos>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttQoS: int value()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean willFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: boolean cleanSession>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: int keepAliveSecs>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectVariableHeader: void <init>(java.lang.String,int,boolean,boolean,boolean,int,boolean,boolean,int)>(v, v, v, v, v, v, v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectPayload;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String clientId>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String willTopic>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: byte[] willMessage>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: java.lang.String username>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttMessageBuilders$ConnectBuilder: byte[] password>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectPayload: void <init>(java.lang.String,java.lang.String,byte[],java.lang.String,byte[])>(v, v, v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttFixedHeader,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectVariableHeader,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.mqtt.MqttConnectPayload)>(v, v, v);
return v;
}
}