class io.quarkus.vertx.runtime.VertxRecorder$3 extends java.lang.Object implements io.vertx.core.Handler
{
final java.util.Map$Entry val$entry;
final io.vertx.core.eventbus.EventBus val$eventBus;
final java.lang.String val$address;
final io.quarkus.vertx.runtime.EventConsumerInvoker val$invoker;
final io.vertx.core.impl.ContextInternal val$context;
final java.util.concurrent.CountDownLatch val$latch;
final java.util.List val$registrationFailures;
final io.quarkus.vertx.runtime.VertxRecorder this$0;
void <init>(io.quarkus.vertx.runtime.VertxRecorder, java.util.Map$Entry, io.vertx.core.eventbus.EventBus, java.lang.String, io.quarkus.vertx.runtime.EventConsumerInvoker, io.vertx.core.impl.ContextInternal, java.util.concurrent.CountDownLatch, java.util.List)
{
java.util.Map$Entry v;
io.vertx.core.impl.ContextInternal v;
io.quarkus.vertx.runtime.VertxRecorder v;
java.util.concurrent.CountDownLatch v;
java.util.List v;
io.vertx.core.eventbus.EventBus v;
io.quarkus.vertx.runtime.VertxRecorder$3 v;
java.lang.String v;
io.quarkus.vertx.runtime.EventConsumerInvoker v;
v := @this: io.quarkus.vertx.runtime.VertxRecorder$3;
v := @parameter: io.quarkus.vertx.runtime.VertxRecorder;
v := @parameter: java.util.Map$Entry;
v := @parameter: io.vertx.core.eventbus.EventBus;
v := @parameter: java.lang.String;
v := @parameter: io.quarkus.vertx.runtime.EventConsumerInvoker;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: java.util.concurrent.CountDownLatch;
v := @parameter: java.util.List;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.quarkus.vertx.runtime.VertxRecorder this$0> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.util.Map$Entry val$entry> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.vertx.core.eventbus.EventBus val$eventBus> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.lang.String val$address> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.quarkus.vertx.runtime.EventConsumerInvoker val$invoker> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.vertx.core.impl.ContextInternal val$context> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.util.concurrent.CountDownLatch val$latch> = v;
v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.util.List val$registrationFailures> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void handle(java.lang.Void)
{
java.lang.Void v;
java.util.Map$Entry v;
io.quarkus.vertx.runtime.VertxRecorder$3$2 v;
io.quarkus.vertx.runtime.VertxRecorder$3$1 v;
java.util.List v;
io.vertx.core.eventbus.EventBus v, v;
io.quarkus.vertx.runtime.VertxRecorder$3 v;
java.lang.Object v;
java.lang.String v, v;
io.vertx.core.eventbus.MessageConsumer v;
boolean v;
v := @this: io.quarkus.vertx.runtime.VertxRecorder$3;
v := @parameter: java.lang.Void;
v = v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.util.Map$Entry val$entry>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<io.quarkus.vertx.ConsumeEvent: boolean local()>();
if v == 0 goto label;
v = v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.vertx.core.eventbus.EventBus val$eventBus>;
v = v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.lang.String val$address>;
v = interfaceinvoke v.<io.vertx.core.eventbus.EventBus: io.vertx.core.eventbus.MessageConsumer localConsumer(java.lang.String)>(v);
goto label;
label:
v = v.<io.quarkus.vertx.runtime.VertxRecorder$3: io.vertx.core.eventbus.EventBus val$eventBus>;
v = v.<io.quarkus.vertx.runtime.VertxRecorder$3: java.lang.String val$address>;
v = interfaceinvoke v.<io.vertx.core.eventbus.EventBus: io.vertx.core.eventbus.MessageConsumer consumer(java.lang.String)>(v);
label:
v = new io.quarkus.vertx.runtime.VertxRecorder$3$1;
specialinvoke v.<io.quarkus.vertx.runtime.VertxRecorder$3$1: void <init>(io.quarkus.vertx.runtime.VertxRecorder$3)>(v);
interfaceinvoke v.<io.vertx.core.eventbus.MessageConsumer: io.vertx.core.eventbus.MessageConsumer handler(io.vertx.core.Handler)>(v);
v = new io.quarkus.vertx.runtime.VertxRecorder$3$2;
specialinvoke v.<io.quarkus.vertx.runtime.VertxRecorder$3$2: void <init>(io.quarkus.vertx.runtime.VertxRecorder$3)>(v);
interfaceinvoke v.<io.vertx.core.eventbus.MessageConsumer: void completionHandler(io.vertx.core.Handler)>(v);
v = <io.quarkus.vertx.runtime.VertxRecorder: java.util.List messageConsumers>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
}