cancelTimer, close, close, clusteredVertx, createDatagramSocket, createDatagramSocket, createDnsClient, createDnsClient, createDnsClient, createHttpClient, createHttpClient, createHttpServer, createHttpServer, createNetClient, createNetClient, createNetServer, createNetServer, currentContext, deploymentIDs, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, deployVerticle, eventBus, exceptionHandler, exceptionHandler, executeBlocking, executeBlocking, fileSystem, isClustered, isNativeTransportEnabled, nettyEventLoopGroup, periodicStream, registerVerticleFactory, runOnContext, setPeriodic, setTimer, sharedData, timerStream, undeploy, undeploy, unregisterVerticleFactory, verticleFactories, vertx, vertxisMetricsEnabledlong maxEventLoopExecTime()
TimeUnit maxEventLoopExecTimeUnit()
ContextInternal getOrCreateContext()
VertxgetOrCreateContext in interface Vertxio.netty.channel.EventLoopGroup getEventLoopGroup()
io.netty.channel.EventLoopGroup getAcceptorEventLoopGroup()
ExecutorService getWorkerPool()
Map<ServerID,HttpServerImpl> sharedHttpServers()
Map<ServerID,NetServerImpl> sharedNetServers()
VertxMetrics metricsSPI()
Transport transport()
ContextInternal getContext()
ContextInternal createEventLoopContext(String deploymentID, WorkerPool workerPool, JsonObject config, ClassLoader tccl)
ContextInternal createEventLoopContext(io.netty.channel.EventLoop eventLoop, WorkerPool workerPool, ClassLoader tccl)
ContextInternal createWorkerContext(boolean multiThreaded, String deploymentID, WorkerPool pool, JsonObject config, ClassLoader tccl)
WorkerExecutorInternal createSharedWorkerExecutor(String name)
VertxVertx.createSharedWorkerExecutor(String, int) but with the VertxOptions.setWorkerPoolSize(int) poolSize.createSharedWorkerExecutor in interface VertxWorkerExecutorInternal createSharedWorkerExecutor(String name, int poolSize)
VertxVertx.createSharedWorkerExecutor(String, int, long) but with the VertxOptions.setMaxWorkerExecuteTime(long) maxExecuteTime.createSharedWorkerExecutor in interface VertxWorkerExecutorInternal createSharedWorkerExecutor(String name, int poolSize, long maxExecuteTime)
VertxVertx.createSharedWorkerExecutor(String, int, long, TimeUnit) but with the ns unit.createSharedWorkerExecutor in interface VertxWorkerExecutorInternal createSharedWorkerExecutor(String name, int poolSize, long maxExecuteTime, TimeUnit maxExecuteTimeUnit)
Vertxname. Executors with the same name will share
the same worker pool. The worker pool size , max execute time and unit of max execute time are set when the worker pool is created and
won't change after.
The worker pool is released when all the WorkerExecutor sharing the same name are closed.
createSharedWorkerExecutor in interface Vertxname - the name of the worker executorpoolSize - the size of the poolmaxExecuteTime - the value of max worker execute timemaxExecuteTimeUnit - the value of unit of max worker execute timevoid simulateKill()
Deployment getDeployment(String deploymentID)
void failoverCompleteHandler(FailoverCompleteHandler failoverCompleteHandler)
boolean isKilled()
void failDuringFailover(boolean fail)
String getNodeID()
<T> void executeBlockingInternal(Handler<Promise<T>> blockingCodeHandler, Handler<AsyncResult<T>> resultHandler)
Vertx.executeBlocking(Handler, Handler) but using the internal worker thread pool.ClusterManager getClusterManager()
HAManager haManager()
void resolveAddress(String hostname, Handler<AsyncResult<InetAddress>> resultHandler)
vertx.io into the first found A (IPv4) or AAAA (IPv6) record.hostname - the hostname to resolveresultHandler - the result handlerAddressResolver addressResolver()
io.netty.resolver.AddressResolverGroup<InetSocketAddress> nettyAddressResolverGroup()
AddressResolverGroup to use in a Netty BootstrapBlockedThreadChecker blockedThreadChecker()
void addCloseHook(Closeable hook)
void removeCloseHook(Closeable hook)
Copyright © 2020. All rights reserved.