public class io.quarkus.mutiny.runtime.MutinyInfrastructure extends java.lang.Object
{
public static final java.lang.String VERTX_EVENT_LOOP_THREAD_PREFIX;
public void <init>()
{
io.quarkus.mutiny.runtime.MutinyInfrastructure v;
v := @this: io.quarkus.mutiny.runtime.MutinyInfrastructure;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void configureMutinyInfrastructure(java.util.concurrent.ScheduledExecutorService, io.quarkus.runtime.ShutdownContext, org.jboss.threads.ContextHandler)
{
java.util.concurrent.ScheduledExecutorService v, v;
io.quarkus.runtime.ShutdownContext v;
org.jboss.threads.ContextHandler v;
io.quarkus.mutiny.runtime.MutinyInfrastructure v;
v := @this: io.quarkus.mutiny.runtime.MutinyInfrastructure;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
v := @parameter: io.quarkus.runtime.ShutdownContext;
v := @parameter: org.jboss.threads.ContextHandler;
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.ScheduledExecutorService getDefaultWorkerPool()>();
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: void shutdown()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setDefaultExecutor(java.util.concurrent.Executor)>(v);
return;
}
public void configureDroppedExceptionHandler()
{
io.quarkus.mutiny.runtime.MutinyInfrastructure$1 v;
io.quarkus.mutiny.runtime.MutinyInfrastructure v;
org.jboss.logging.Logger v;
v := @this: io.quarkus.mutiny.runtime.MutinyInfrastructure;
v = staticinvoke <org.jboss.logging.Logger: org.jboss.logging.Logger getLogger(java.lang.Class)>(class "Lio/quarkus/mutiny/runtime/MutinyInfrastructure;");
v = new io.quarkus.mutiny.runtime.MutinyInfrastructure$1;
specialinvoke v.<io.quarkus.mutiny.runtime.MutinyInfrastructure$1: void <init>(io.quarkus.mutiny.runtime.MutinyInfrastructure,org.jboss.logging.Logger)>(v, v);
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setDroppedExceptionHandler(java.util.function.Consumer)>(v);
return;
}
public void configureThreadBlockingChecker()
{
io.quarkus.mutiny.runtime.MutinyInfrastructure$2 v;
io.quarkus.mutiny.runtime.MutinyInfrastructure v;
v := @this: io.quarkus.mutiny.runtime.MutinyInfrastructure;
v = new io.quarkus.mutiny.runtime.MutinyInfrastructure$2;
specialinvoke v.<io.quarkus.mutiny.runtime.MutinyInfrastructure$2: void <init>(io.quarkus.mutiny.runtime.MutinyInfrastructure)>(v);
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setCanCallerThreadBeBlockedSupplier(java.util.function.BooleanSupplier)>(v);
return;
}
public void configureOperatorLogger()
{
io.quarkus.mutiny.runtime.MutinyInfrastructure$3 v;
io.quarkus.mutiny.runtime.MutinyInfrastructure v;
org.jboss.logging.Logger v;
v := @this: io.quarkus.mutiny.runtime.MutinyInfrastructure;
v = staticinvoke <org.jboss.logging.Logger: org.jboss.logging.Logger getLogger(java.lang.Class)>(class "Lio/quarkus/mutiny/runtime/MutinyInfrastructure;");
v = new io.quarkus.mutiny.runtime.MutinyInfrastructure$3;
specialinvoke v.<io.quarkus.mutiny.runtime.MutinyInfrastructure$3: void <init>(io.quarkus.mutiny.runtime.MutinyInfrastructure,org.jboss.logging.Logger)>(v, v);
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setOperatorLogger(io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger)>(v);
return;
}
}