public class io.vertx.core.eventbus.impl.MessageProducerImpl extends java.lang.Object implements io.vertx.core.eventbus.MessageProducer
{
private final io.vertx.core.Vertx vertx;
private final io.vertx.core.eventbus.impl.EventBusImpl bus;
private final boolean send;
private final java.lang.String address;
private io.vertx.core.eventbus.DeliveryOptions options;
public void <init>(io.vertx.core.Vertx, java.lang.String, boolean, io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.eventbus.EventBus v;
io.vertx.core.Vertx v;
java.lang.String v;
boolean v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: io.vertx.core.Vertx;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.Vertx vertx> = v;
v = interfaceinvoke v.<io.vertx.core.Vertx: io.vertx.core.eventbus.EventBus eventBus()>();
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.impl.EventBusImpl bus> = v;
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: java.lang.String address> = v;
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: boolean send> = v;
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.DeliveryOptions options> = v;
return;
}
public synchronized io.vertx.core.eventbus.MessageProducer deliveryOptions(io.vertx.core.eventbus.DeliveryOptions)
{
io.vertx.core.eventbus.DeliveryOptions v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: io.vertx.core.eventbus.DeliveryOptions;
v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.DeliveryOptions options> = v;
return v;
}
public io.vertx.core.Future write(java.lang.Object)
{
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.Vertx v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Future v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: java.lang.Object;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.Vertx vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
specialinvoke v.<io.vertx.core.eventbus.impl.MessageProducerImpl: void write(java.lang.Object,io.vertx.core.Promise)>(v, v);
v = interfaceinvoke v.<io.vertx.core.Promise: io.vertx.core.Future future()>();
return v;
}
public void write(java.lang.Object, io.vertx.core.Handler)
{
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.Vertx v;
io.vertx.core.impl.ContextInternal v;
java.lang.Object v;
io.vertx.core.Handler v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.Handler;
v = null;
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.Vertx vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise(io.vertx.core.Handler)>(v);
label:
specialinvoke v.<io.vertx.core.eventbus.impl.MessageProducerImpl: void write(java.lang.Object,io.vertx.core.Promise)>(v, v);
return;
}
private void write(java.lang.Object, io.vertx.core.Promise)
{
io.vertx.core.eventbus.impl.EventBusImpl v, v;
io.vertx.core.eventbus.DeliveryOptions v, v, v;
io.vertx.core.Promise v;
io.vertx.core.MultiMap v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
io.vertx.core.eventbus.impl.MessageImpl v;
java.lang.Object v;
java.lang.String v, v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: java.lang.Object;
v := @parameter: io.vertx.core.Promise;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: boolean send>;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: java.lang.String address>;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.DeliveryOptions options>;
v = virtualinvoke v.<io.vertx.core.eventbus.DeliveryOptions: io.vertx.core.MultiMap getHeaders()>();
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.DeliveryOptions options>;
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)>(v, v, v, v, v);
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.impl.EventBusImpl bus>;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.eventbus.DeliveryOptions options>;
virtualinvoke v.<io.vertx.core.eventbus.impl.EventBusImpl: void sendOrPubInternal(io.vertx.core.eventbus.impl.MessageImpl,io.vertx.core.eventbus.DeliveryOptions,io.vertx.core.eventbus.impl.ReplyHandler,io.vertx.core.Promise)>(v, v, null, v);
return;
}
public java.lang.String address()
{
java.lang.String v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: java.lang.String address>;
return v;
}
public io.vertx.core.Future close()
{
io.vertx.core.Vertx v;
io.vertx.core.Context v;
io.vertx.core.Future v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v = v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.Vertx vertx>;
v = interfaceinvoke v.<io.vertx.core.Vertx: io.vertx.core.Context getOrCreateContext()>();
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.Future succeededFuture()>();
return v;
}
public void close(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.Future v;
io.vertx.core.eventbus.impl.MessageProducerImpl v;
v := @this: io.vertx.core.eventbus.impl.MessageProducerImpl;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.vertx.core.eventbus.impl.MessageProducerImpl: io.vertx.core.Future close()>();
if v == null goto label;
interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future onComplete(io.vertx.core.Handler)>(v);
label:
return;
}
}