Package io.smallrye.reactive.messaging.connectors

Class WorkerPoolRegistry

java.lang.Object

io.smallrye.reactive.messaging.connectors.WorkerPoolRegistry

@ApplicationScoped
public class WorkerPoolRegistry
extends Object

Constructor Summary

Constructors

Constructor	Description
WorkerPoolRegistry()

Method Summary

Modifier and Type	Method	Description
<T> void	analyzeWorker(javax.enterprise.inject.spi.AnnotatedType<T> annotatedType)
void	defineWorker(String className, String method, String poolName)
<T> io.smallrye.mutiny.Uni<T>	executeWork(io.vertx.core.Handler<io.vertx.mutiny.core.Promise<T>> blockingCodeHandler, String workerName, boolean ordered)
void	terminate(Object event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

defineWorker

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