public class io.vertx.core.eventbus.impl.MessageImpl extends java.lang.Object implements io.vertx.core.eventbus.Message
{
protected io.vertx.core.eventbus.MessageCodec messageCodec;
protected final io.vertx.core.eventbus.impl.EventBusImpl bus;
protected java.lang.String address;
protected java.lang.String replyAddress;
protected io.vertx.core.MultiMap headers;
protected java.lang.Object sentBody;
protected java.lang.Object receivedBody;
protected boolean send;
protected java.lang.Object trace;
public void <init>(io.vertx.core.eventbus.impl.EventBusImpl)
{
io.vertx.core.eventbus.impl.EventBusImpl v;
io.vertx.core.eventbus.impl.MessageImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: io.vertx.core.eventbus.impl.EventBusImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus> = v;
return;
}
public void <init>(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.eventbus.MessageCodec v;
io.vertx.core.MultiMap v;
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
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.<java.lang.Object: void <init>()>();
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec> = v;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String address> = v;
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers> = v;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody> = v;
v.<io.vertx.core.eventbus.impl.MessageImpl: boolean send> = v;
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus> = v;
return;
}
protected void <init>(io.vertx.core.eventbus.impl.MessageImpl)
{
io.vertx.core.MultiMap v, v, v, v;
java.lang.String v, v;
boolean v, v;
io.vertx.core.eventbus.impl.EventBusImpl v;
java.util.Iterator v;
java.util.List v;
io.vertx.core.eventbus.MessageCodec v, v;
io.vertx.core.eventbus.impl.MessageImpl v, v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: io.vertx.core.eventbus.impl.MessageImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus> = v;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String address>;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String address> = v;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress>;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress> = v;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec>;
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec> = v;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers>;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<io.vertx.core.MultiMap: java.util.List entries()>();
v = staticinvoke <io.vertx.core.MultiMap: io.vertx.core.MultiMap caseInsensitiveMultiMap()>();
v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers> = v;
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 = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<io.vertx.core.MultiMap: io.vertx.core.MultiMap add(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody>;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody>;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody> = v;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.Object transform(java.lang.Object)>(v);
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object receivedBody> = v;
label:
v = v.<io.vertx.core.eventbus.impl.MessageImpl: boolean send>;
v.<io.vertx.core.eventbus.impl.MessageImpl: boolean send> = v;
return;
}
public io.vertx.core.eventbus.impl.MessageImpl copyBeforeReceive()
{
io.vertx.core.eventbus.impl.MessageImpl v, v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = new io.vertx.core.eventbus.impl.MessageImpl;
specialinvoke v.<io.vertx.core.eventbus.impl.MessageImpl: void <init>(io.vertx.core.eventbus.impl.MessageImpl)>(v);
return v;
}
public java.lang.String address()
{
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String address>;
return v;
}
public io.vertx.core.MultiMap headers()
{
io.vertx.core.MultiMap v, v, v;
io.vertx.core.eventbus.impl.MessageImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: 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.MessageImpl: io.vertx.core.MultiMap headers> = v;
label:
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.MultiMap headers>;
return v;
}
public java.lang.Object body()
{
io.vertx.core.eventbus.MessageCodec v;
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.Object v, v, v, v, v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object receivedBody>;
if v != null goto label;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody>;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec>;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object sentBody>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.Object transform(java.lang.Object)>(v);
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object receivedBody> = v;
label:
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object receivedBody>;
return v;
}
public java.lang.String replyAddress()
{
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress>;
return v;
}
public void reply(java.lang.Object, io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.impl.EventBusImpl v;
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.eventbus.impl.MessageImpl v, v;
java.lang.Object v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress>;
if v == null goto label;
v = virtualinvoke 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.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
virtualinvoke v.<io.vertx.core.eventbus.impl.EventBusImpl: void sendReply(io.vertx.core.eventbus.impl.MessageImpl,io.vertx.core.eventbus.DeliveryOptions,io.vertx.core.eventbus.impl.ReplyHandler)>(v, v, null);
label:
return;
}
public io.vertx.core.Future replyAndRequest(java.lang.Object, io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.impl.EventBusImpl v, v;
java.lang.IllegalStateException v;
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.Future v;
io.vertx.core.eventbus.impl.ReplyHandler v;
io.vertx.core.eventbus.impl.MessageImpl v, v;
java.lang.Object v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress>;
if v == null goto label;
v = virtualinvoke 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.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
v = virtualinvoke v.<io.vertx.core.eventbus.impl.EventBusImpl: io.vertx.core.eventbus.impl.ReplyHandler createReplyHandler(io.vertx.core.eventbus.impl.MessageImpl,boolean,io.vertx.core.eventbus.DeliveryOptions)>(v, 0, v);
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
virtualinvoke v.<io.vertx.core.eventbus.impl.EventBusImpl: void sendReply(io.vertx.core.eventbus.impl.MessageImpl,io.vertx.core.eventbus.DeliveryOptions,io.vertx.core.eventbus.impl.ReplyHandler)>(v, v, v);
v = virtualinvoke v.<io.vertx.core.eventbus.impl.ReplyHandler: io.vertx.core.Future result()>();
return v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>()>();
throw v;
}
protected io.vertx.core.eventbus.impl.MessageImpl createReply(java.lang.Object, io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.impl.EventBusImpl v;
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.MultiMap v;
io.vertx.core.eventbus.impl.MessageImpl v, v;
java.lang.Object v, v;
java.lang.String v, v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress>;
v = virtualinvoke v.<io.vertx.core.eventbus.DeliveryOptions: io.vertx.core.MultiMap getHeaders()>();
v = virtualinvoke v.<io.vertx.core.eventbus.DeliveryOptions: java.lang.String getCodecName()>();
v = virtualinvoke v.<io.vertx.core.eventbus.impl.EventBusImpl: io.vertx.core.eventbus.impl.MessageImpl createMessage(boolean,java.lang.String,io.vertx.core.MultiMap,java.lang.Object,java.lang.String)>(1, v, v, v, v);
v = v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object trace>;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.Object trace> = v;
return v;
}
public boolean isSend()
{
io.vertx.core.eventbus.impl.MessageImpl v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: boolean send>;
return v;
}
public void setReplyAddress(java.lang.String)
{
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v := @parameter: java.lang.String;
v.<io.vertx.core.eventbus.impl.MessageImpl: java.lang.String replyAddress> = v;
return;
}
public io.vertx.core.eventbus.MessageCodec codec()
{
io.vertx.core.eventbus.impl.MessageImpl v;
io.vertx.core.eventbus.MessageCodec v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
v = v.<io.vertx.core.eventbus.impl.MessageImpl: io.vertx.core.eventbus.MessageCodec messageCodec>;
return v;
}
protected boolean isLocal()
{
io.vertx.core.eventbus.impl.MessageImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageImpl;
return 1;
}
}