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.smallrye.mutiny.Uni<T> uni,
                                                         String workerName,
                                                         boolean ordered)
      • analyzeWorker

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

        public void defineWorker​(String className,
                                 String method,
                                 String poolName)