public class io.vertx.core.eventbus.impl.clustered.ClusteredMessage extends io.vertx.core.eventbus.impl.MessageImpl
{
private static final io.vertx.core.impl.logging.Logger log;
private static final byte WIRE_PROTOCOL_VERSION;
private java.lang.String sender;
private java.lang.String repliedTo;
private io.vertx.core.buffer.Buffer wireBuffer;
private int bodyPos;
private int headersPos;
private boolean fromWire;
private boolean toWire;
private java.lang.String failure;
public void <init>(io.vertx.core.eventbus.impl.EventBusImpl)
{
io.vertx.core.eventbus.impl.EventBusImpl v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.eventbus.impl.EventBusImpl;
specialinvoke v.<io.vertx.core.eventbus.impl.MessageImpl: void <init>(io.vertx.core.eventbus.impl.EventBusImpl)>(v);
return;
}
public void <init>(java.lang.String, java.lang.String, io.vertx.core.MultiMap, java.lang.Object, io.vertx.core.eventbus.MessageCodec, boolean, io.vertx.core.eventbus.impl.EventBusImpl)
{
io.vertx.core.eventbus.impl.EventBusImpl v;
io.vertx.core.MultiMap v;
io.vertx.core.eventbus.MessageCodec v;
java.lang.Object v;
java.lang.String v, v;
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: io.vertx.core.MultiMap;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.eventbus.MessageCodec;
v := @parameter: boolean;
v := @parameter: io.vertx.core.eventbus.impl.EventBusImpl;
specialinvoke v.<io.vertx.core.eventbus.impl.MessageImpl: void <init>(java.lang.String,io.vertx.core.MultiMap,java.lang.Object,io.vertx.core.eventbus.MessageCodec,boolean,io.vertx.core.eventbus.impl.EventBusImpl)>(v, v, v, v, v, v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender> = v;
return;
}
protected void <init>(io.vertx.core.eventbus.impl.clustered.ClusteredMessage)
{
io.vertx.core.buffer.Buffer v;
int v, v;
java.lang.Object v;
java.lang.String v;
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v, v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
specialinvoke v.<io.vertx.core.eventbus.impl.MessageImpl: void <init>(io.vertx.core.eventbus.impl.MessageImpl)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.Object sentBody>;
if v != null goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean fromWire>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean fromWire> = v;
return;
}
protected io.vertx.core.eventbus.impl.MessageImpl createReply(java.lang.Object, io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.Object v;
java.lang.String v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
v = specialinvoke v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.MessageImpl createReply(java.lang.Object,io.vertx.core.eventbus.DeliveryOptions)>(v, v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender>;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String repliedTo> = v;
return v;
}
public io.vertx.core.eventbus.impl.clustered.ClusteredMessage copyBeforeReceive()
{
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v, v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = new io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void <init>(io.vertx.core.eventbus.impl.clustered.ClusteredMessage)>(v);
return v;
}
public io.vertx.core.MultiMap headers()
{
int v;
io.vertx.core.MultiMap v, v, v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
if v != null goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void decodeHeaders()>();
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
if v != null goto label;
v = staticinvoke <io.vertx.core.MultiMap: io.vertx.core.MultiMap caseInsensitiveMultiMap()>();
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers> = v;
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
return v;
}
public java.lang.Object body()
{
int v;
java.lang.Object v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.Object receivedBody>;
if v != null goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos>;
if v == 0 goto label;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void decodeBody()>();
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.Object receivedBody>;
return v;
}
public java.lang.String replyAddress()
{
java.lang.String v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String replyAddress>;
return v;
}
public io.vertx.core.buffer.Buffer encodeToWire()
{
io.vertx.core.eventbus.MessageCodec v, v;
byte v, v;
io.vertx.core.buffer.Buffer v;
int v, v, v;
java.lang.String v, v, v, v, v;
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean toWire> = 1;
v = staticinvoke <io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer buffer(int)>(1024);
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(0);
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendByte(byte)>(2);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: byte systemCodecID()>();
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendByte(byte)>(v);
v = (int) -1;
if v != v goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean send>;
if v == 0 goto label;
v = 0;
goto label;
label:
v = 1;
label:
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendByte(byte)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String address>;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String replyAddress>;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String replyAddress>;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
goto label;
label:
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(0);
label:
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender>;
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void encodeHeaders(io.vertx.core.buffer.Buffer)>(v);
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeBody(io.vertx.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int length()>();
v = v - 4;
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer setInt(int,int)>(0, v);
return v;
}
public void readFromWire(io.vertx.core.buffer.Buffer, io.vertx.core.eventbus.impl.CodecManager)
{
byte[] v, v, v, v;
byte v, v, v;
boolean v;
io.vertx.core.buffer.Buffer v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
io.vertx.core.eventbus.MessageCodec[] v;
java.nio.charset.Charset v, v, v, v;
io.vertx.core.eventbus.impl.CodecManager v;
int v, v, 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;
io.vertx.core.eventbus.MessageCodec v, v, v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.buffer.Buffer;
v := @parameter: io.vertx.core.eventbus.impl.CodecManager;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte getByte(int)>(0);
if v <= 2 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte)>(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[])>("Invalid wire protocol version \u should be <= 2");
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void setFailure(java.lang.String)>(v);
label:
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte getByte(int)>(1);
v = 2;
v = (int) -1;
if v != v goto label;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(2);
v = 6 + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(6, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec getCodec(java.lang.String)>(v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec>;
if v != null goto label;
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[])>("No message codec registered with name \u0001");
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void setFailure(java.lang.String)>(v);
label:
v = 6 + v;
goto label;
label:
v = virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec[] systemCodecs()>();
v = v[v];
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec> = v;
label:
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte getByte(int)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean send> = v;
v = v + 1;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v + 4;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(v, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String address> = v;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v + 4;
if v == 0 goto label;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(v, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String replyAddress> = v;
v = v + v;
label:
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v + 4;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(v, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender> = v;
v = v + v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v + v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos> = v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer> = v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean fromWire> = 1;
return;
}
private void setFailure(java.lang.String)
{
java.lang.String v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String failure>;
if v != null goto label;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String failure> = v;
label:
return;
}
private void decodeBody()
{
io.vertx.core.eventbus.MessageCodec v;
io.vertx.core.buffer.Buffer v;
int v;
java.lang.Object v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.Object decodeFromWire(int,io.vertx.core.buffer.Buffer)>(v, v);
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.Object receivedBody> = v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int bodyPos> = 0;
return;
}
private void encodeHeaders(io.vertx.core.buffer.Buffer)
{
io.vertx.core.MultiMap v, v, v, v;
int v, v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.List v, v;
io.vertx.core.buffer.Buffer v;
java.lang.Object v, v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.buffer.Buffer;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int length()>();
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(0);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: java.util.List entries()>();
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: java.util.List entries()>();
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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
specialinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void writeString(io.vertx.core.buffer.Buffer,java.lang.String)>(v, v);
goto label;
label:
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int length()>();
v = v - v;
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer setInt(int,int)>(v, v);
goto label;
label:
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(4);
label:
return;
}
private void decodeHeaders()
{
byte[] v, v;
io.vertx.core.MultiMap v, v;
io.vertx.core.buffer.Buffer v, v, v, v, v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
java.nio.charset.Charset 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;
java.lang.String v, v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
if v == 4 goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + 4;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + 4;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = staticinvoke <io.vertx.core.MultiMap: io.vertx.core.MultiMap caseInsensitiveMultiMap()>();
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers> = v;
v = 0;
label:
if v >= v goto label;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + 4;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(v, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int getInt(int)>(v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + 4;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.buffer.Buffer wireBuffer>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + v;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: byte[] getBytes(int,int)>(v, v);
v = new java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos>;
v = v + v;
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = v;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.MultiMap headers>;
interfaceinvoke v.<io.vertx.core.MultiMap: io.vertx.core.MultiMap add(java.lang.String,java.lang.String)>(v, v);
v = v + 1;
goto label;
label:
v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: int headersPos> = 0;
return;
}
private void writeBody(io.vertx.core.buffer.Buffer)
{
io.vertx.core.eventbus.MessageCodec v;
io.vertx.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.buffer.Buffer;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.Object sentBody>;
interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: void encodeToWire(io.vertx.core.buffer.Buffer,java.lang.Object)>(v, v);
return;
}
private void writeString(io.vertx.core.buffer.Buffer, java.lang.String)
{
byte[] v;
io.vertx.core.buffer.Buffer v;
java.nio.charset.Charset v;
int v;
java.lang.String v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v := @parameter: io.vertx.core.buffer.Buffer;
v := @parameter: java.lang.String;
v = <io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendInt(int)>(v);
interfaceinvoke v.<io.vertx.core.buffer.Buffer: io.vertx.core.buffer.Buffer appendBytes(byte[])>(v);
return;
}
java.lang.String getSender()
{
java.lang.String v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String sender>;
return v;
}
java.lang.String getRepliedTo()
{
java.lang.String v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String repliedTo>;
return v;
}
public boolean isFromWire()
{
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean fromWire>;
return v;
}
public boolean isToWire()
{
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean toWire>;
return v;
}
protected boolean isLocal()
{
boolean v, v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = virtualinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: boolean isFromWire()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
boolean hasFailure()
{
java.lang.String v;
boolean v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String failure>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
void internalError()
{
io.vertx.core.impl.logging.Logger v;
io.vertx.core.eventbus.ReplyFailure v;
java.lang.String v, v, v;
io.vertx.core.eventbus.ReplyException v;
io.vertx.core.eventbus.impl.clustered.ClusteredMessage v;
v := @this: io.vertx.core.eventbus.impl.clustered.ClusteredMessage;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String replyAddress>;
if v == null goto label;
v = new io.vertx.core.eventbus.ReplyException;
v = <io.vertx.core.eventbus.ReplyFailure: io.vertx.core.eventbus.ReplyFailure ERROR>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String failure>;
specialinvoke v.<io.vertx.core.eventbus.ReplyException: void <init>(io.vertx.core.eventbus.ReplyFailure,java.lang.String)>(v, v);
virtualinvoke v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: void reply(java.lang.Object)>(v);
goto label;
label:
v = <io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.impl.logging.Logger log>;
v = v.<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: java.lang.String failure>;
interfaceinvoke v.<io.vertx.core.impl.logging.Logger: void error(java.lang.Object)>(v);
label:
return;
}
static void <clinit>()
{
io.vertx.core.impl.logging.Logger v;
v = staticinvoke <io.vertx.core.impl.logging.LoggerFactory: io.vertx.core.impl.logging.Logger getLogger(java.lang.Class)>(class "Lio/vertx/core/eventbus/impl/clustered/ClusteredMessage;");
<io.vertx.core.eventbus.impl.clustered.ClusteredMessage: io.vertx.core.impl.logging.Logger log> = v;
return;
}
}