Class WorkerPoolRegistry


  • @ApplicationScoped
    public class WorkerPoolRegistry
    extends Object
    • Constructor Detail

      • WorkerPoolRegistry

        public WorkerPoolRegistry()
    • Method Detail

      • terminate

        public void terminate​(@Observes(notifyObserver=IF_EXISTS) @Priority(100) @BeforeDestroyed(javax.enterprise.context.ApplicationScoped.class)
                              Object event)
      • executeWork

        public <T> io.smallrye.mutiny.Uni<T> executeWork​(io.vertx.core.Handler<io.vertx.mutiny.core.Promise<T>> blockingCodeHandler,
                                                         String workerName,
                                                         boolean ordered)
      • analyzeWorker

        public <T> void analyzeWorker​(javax.enterprise.inject.spi.AnnotatedType<T> annotatedType)
      • methodAsString

        public String methodAsString​(Method method)