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)
<T> io.smallrye.mutiny.Uni<T>	executeWork(io.vertx.core.Handler<io.vertx.mutiny.core.Promise<T>> blockingCodeHandler, String workerName, boolean ordered)
String	methodAsString(Method method)
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)

methodAsString

public String methodAsString(Method method)