Vert.x 4.5.13 · io.vertx.core.impl.VertxImpl · APIdia, the JavaDoc alternative

Modifier and Type	Class and Description
pack-priv static class	VertxImpl.ContextDispatch
pack-priv class	VertxImpl.InternalTimerHandler Timers are stored in the `timeouts` map at creation time.
pack-priv class	VertxImpl.SharedWorkerPool
private class	VertxImpl.TimeoutStreamImpl References Deprecated `TimeoutStream` is deprecated or references (maybe indirectly) at least one deprecated element.

Modifier and Type	Field and Description
private final EventLoopGroup	acceptorEventLoopGroup
private final AddressResolver	addressResolver
private final AddressResolverOptions	addressResolverOptions
private final BlockedThreadChecker	checker
private boolean	closed
private final CloseFuture	closeFuture
private static final String	CLUSTER_MAP_NAME
private final ClusterManager	clusterManager
private final ContextLocal<?>[]	contextLocals
private final List<ContextLocal<?>>	contextLocalsList
private final int	defaultWorkerPoolSize
private final DeploymentManager	deploymentManager
private final boolean	disableTCCL
private final EventBusInternal	eventBus
private final EventLoopGroup	eventLoopGroup
private final ThreadFactory	eventLoopThreadFactory
private volatile Handler<Throwable>	exceptionHandler
private final ExecutorServiceFactory	executorServiceFactory
private final FileResolver	fileResolver
private final FileSystem	fileSystem
private volatile HAManager	haManager
pack-priv final WorkerPool	internalWorkerPool
private static final Logger	log
private final long	maxEventLoopExecTime
private final TimeUnit	maxEventLoopExecTimeUnit
private final long	maxWorkerExecTime
private final TimeUnit	maxWorkerExecTimeUnit
private final VertxMetrics	metrics
private final Map<String, VertxImpl.SharedWorkerPool>	namedWorkerPools
private static final int	NETTY_IO_RATIO
private static final String	NETTY_IO_RATIO_PROPERTY_NAME
private final NodeSelector	nodeSelector
pack-priv static final ThreadLocal<VertxImpl.ContextDispatch>	nonVertxContextDispatch Context dispatch info for context running with non vertx threads (Loom).
private final SharedData	sharedData
private final Map<ServerID, HttpServerImpl>	sharedHttpServers
private final Map<ServerID, NetServerImpl>	sharedNetServers
private final ThreadLocal<WeakReference<ContextInternal>>	stickyContext
private final VertxThreadFactory	threadFactory
private final AtomicLong	timeoutCounter
private final ConcurrentMap<Long, VertxImpl.InternalTimerHandler>	timeouts
private final VertxTracer<I, O>	tracer
private final Transport	transport
private final Boolean	useDaemonThread
private final VerticleManager	verticleManager
private final ExecutorService	virtualThreadExecutor
pack-priv final WorkerPool	virtualThreaWorkerPool
pack-priv final WorkerPool	workerPool

Access	Constructor and Description
pack-priv	VertxImpl(VertxOptions options, ClusterManager clusterManager, NodeSelector nodeSelector, VertxMetrics metrics, VertxTracer<?, ?> tracer, Transport transport, FileResolver fileResolver, VertxThreadFactory threadFactory, ExecutorServiceFactory executorServiceFactory)

Method Summary

Modifier and Type	Method and Description
public void	addCloseHook(Closeable hook) Implements io.vertx.core.impl.VertxInternal.addCloseHook.
public AddressResolver	addressResolver() Implements io.vertx.core.impl.VertxInternal.addressResolver.
pack-priv ContextInternal	Returns: the current context that shall be restored beginDispatch(ContextInternal the context on which the event is emitted on context) Begin the emission of a context event.
private ContextInternal	beginDispatch2(Thread thread, ContextInternal context)
public BlockedThreadChecker	blockedThreadChecker() Implements io.vertx.core.impl.VertxInternal.blockedThreadChecker.
public boolean	cancelTimer(long The id of the timer to cancel id) Implements io.vertx.core.Vertx.cancelTimer. Cancels the timer with the specified `id`.
public Future<Void>	close() Implements io.vertx.core.Vertx.close. Stop the Vertx instance and release any resources held by it.
public synchronized void	close(Handler<AsyncResult<Void>> The handler will be notified when the close is complete. completionHandler) Implements io.vertx.core.Vertx.close. Like `close` but the completionHandler will be called when the close is complete
private void	closeClusterManager(Handler<AsyncResult<Void>> completionHandler)
public CloseFuture	closeFuture() Implements io.vertx.core.impl.VertxInternal.closeFuture.
public List<ContextLocal<?>>	contextLocals() Implements io.vertx.core.impl.VertxInternal.contextLocals.
private ContextInternal	createContext(Thread thread)
private ContextImpl	createContext(ThreadingModel threadingModel, EventLoop eventLoop, CloseFuture closeFuture, Deployment deployment, ClassLoader tccl, EventExecutor eventExecutor, WorkerPool wp)
public DatagramSocket	createDatagramSocket(DatagramSocketOptions the options to use options) Implements io.vertx.core.Vertx.createDatagramSocket. Create a datagram socket using the specified options
public DnsClient	createDnsClient(int the port port, String the host host) Implements io.vertx.core.Vertx.createDnsClient. Create a DNS client to connect to a DNS server at the specified host and port, with the default query timeout (5 seconds)
public DnsClient	createDnsClient() Implements io.vertx.core.Vertx.createDnsClient. Create a DNS client to connect to the DNS server configured by `VertxOptions#getAddressResolverOptions()` DNS client takes the first configured resolver address provided by `DnsResolverProvider#nameServerAddresses()`}
public DnsClient	createDnsClient(DnsClientOptions the client options options) Implements io.vertx.core.Vertx.createDnsClient. Create a DNS client to connect to a DNS server
private ContextImpl	createEventLoopContext(EventLoop eventLoop, CloseFuture closeFuture, WorkerPool workerPool, Deployment deployment, ClassLoader tccl)
public ContextImpl	createEventLoopContext(Deployment deployment, CloseFuture closeFuture, WorkerPool workerPool, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createEventLoopContext.
public ContextImpl	createEventLoopContext(EventLoop eventLoop, WorkerPool workerPool, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createEventLoopContext.
public ContextImpl	createEventLoopContext() Implements io.vertx.core.impl.VertxInternal.createEventLoopContext.
private void	createHaManager(VertxOptions options, Promise<Void> initPromise)
public HttpClient	createHttpPoolClient(HttpClientOptions the http client options to use clientOptions, PoolOptions the pool options to use poolOptions, CloseFuture the close future closeFuture) Implements io.vertx.core.impl.VertxInternal.createHttpPoolClient. Create a HTTP/HTTPS client using the specified options and close future
public HttpServer	createHttpServer(HttpServerOptions the options to use serverOptions) Implements io.vertx.core.Vertx.createHttpServer. Create an HTTP/HTTPS server using the specified options
public NetClient	createNetClient(NetClientOptions the options to use options) Implements io.vertx.core.Vertx.createNetClient. Create a TCP/SSL client using the specified options
public NetServer	createNetServer(NetServerOptions the options to use options) Implements io.vertx.core.Vertx.createNetServer. Create a TCP/SSL server using the specified options
public WorkerExecutorImpl	createSharedWorkerExecutor(String name) Implements io.vertx.core.impl.VertxInternal.createSharedWorkerExecutor. Like `createSharedWorkerExecutor(String, int)` but with the `VertxOptions#setWorkerPoolSize` `poolSize`.
public WorkerExecutorImpl	createSharedWorkerExecutor(String name, int poolSize) Implements io.vertx.core.impl.VertxInternal.createSharedWorkerExecutor. Like `createSharedWorkerExecutor(String, int, long)` but with the `VertxOptions#setMaxWorkerExecuteTime` `maxExecuteTime`.
public synchronized WorkerExecutorImpl	createSharedWorkerExecutor(String name, int poolSize, long maxExecuteTime) Implements io.vertx.core.impl.VertxInternal.createSharedWorkerExecutor. Like `createSharedWorkerExecutor(String, int, long, TimeUnit)` but with the `VertxOptions#setMaxWorkerExecuteTimeUnit(TimeUnit)` `maxExecuteTimeUnit`.
public synchronized WorkerExecutorImpl	createSharedWorkerExecutor(String the name of the worker executor name, int the size of the pool poolSize, long the value of max worker execute time maxExecuteTime, TimeUnit the value of unit of max worker execute time maxExecuteTimeUnit) Implements io.vertx.core.impl.VertxInternal.createSharedWorkerExecutor. Create a named worker executor, the executor should be closed when it's not needed anymore to release resources.
public synchronized VertxImpl.SharedWorkerPool	createSharedWorkerPool(String name, int poolSize, long maxExecuteTime, TimeUnit maxExecuteTimeUnit) Implements io.vertx.core.impl.VertxInternal.createSharedWorkerPool.
private static ThreadFactory	createThreadFactory(VertxThreadFactory threadFactory, BlockedThreadChecker checker, Boolean useDaemonThread, long maxExecuteTime, TimeUnit maxExecuteTimeUnit, String prefix, boolean worker)
private ContextImpl	createVirtualThreadContext(EventLoop eventLoop, CloseFuture closeFuture, Deployment deployment, ClassLoader tccl)
public ContextImpl	createVirtualThreadContext(Deployment deployment, CloseFuture closeFuture, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createVirtualThreadContext.
public ContextImpl	createVirtualThreadContext(EventLoop eventLoop, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createVirtualThreadContext.
public ContextImpl	createVirtualThreadContext() Implements io.vertx.core.impl.VertxInternal.createVirtualThreadContext.
public WebSocketClient	createWebSocketClient(WebSocketClientOptions the options to use options, CloseFuture the close future closeFuture) Implements io.vertx.core.impl.VertxInternal.createWebSocketClient. Create a WebSocket client using the specified options and close future
public WebSocketClient	createWebSocketClient(WebSocketClientOptions the options to use options) Implements io.vertx.core.Vertx.createWebSocketClient. Create a WebSocket client using the specified options
private ContextImpl	createWorkerContext(EventLoop eventLoop, CloseFuture closeFuture, WorkerPool workerPool, Deployment deployment, ClassLoader tccl)
public ContextInternal	createWorkerContext(EventLoop eventLoop, WorkerPool workerPool, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createWorkerContext.
public ContextImpl	createWorkerContext(Deployment deployment, CloseFuture closeFuture, WorkerPool workerPool, ClassLoader tccl) Implements io.vertx.core.impl.VertxInternal.createWorkerContext.
public ContextImpl	createWorkerContext() Implements io.vertx.core.impl.VertxInternal.createWorkerContext.
public static ContextInternal	Returns: the current context currentContext(Thread thread)
private void	deleteCacheDirAndShutdown(Handler<AsyncResult<Void>> completionHandler)
public Set<String>	deploymentIDs() Implements io.vertx.core.Vertx.deploymentIDs. Return a Set of deployment IDs for the currently deployed deploymentIDs.
public Future<String>	deployVerticle(String the name name, DeploymentOptions the deployment options. options) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle)` but `io.vertx.core.DeploymentOptions` are provided to configure the deployment.
public void	deployVerticle(String the name name, DeploymentOptions the deployment options. options, Handler<AsyncResult<String>> a handler which will be notified when the deployment is complete completionHandler) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(String, Handler)` but `io.vertx.core.DeploymentOptions` are provided to configure the deployment.
public void	deployVerticle(Verticle the verticle instance to deploy verticle, Handler<AsyncResult<String>> a handler which will be notified when the deployment is complete completionHandler) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle)` but the completionHandler will be notified when the deployment is complete.
public Future<String>	deployVerticle(Verticle the verticle instance to deploy verticle, DeploymentOptions the deployment options. options) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle)` but `io.vertx.core.DeploymentOptions` are provided to configure the deployment.
public void	deployVerticle(Verticle the verticle instance to deploy verticle, DeploymentOptions the deployment options. options, Handler<AsyncResult<String>> a handler which will be notified when the deployment is complete completionHandler) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle, Handler)` but `io.vertx.core.DeploymentOptions` are provided to configure the deployment.
public Future<String>	deployVerticle(Class<? extends Verticle> verticleClass, DeploymentOptions options) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle, DeploymentOptions)` but `Verticle` instance is created by invoking the default constructor of `verticleClass`.
public void	deployVerticle(Class<? extends Verticle> verticleClass, DeploymentOptions options, Handler<AsyncResult<String>> completionHandler) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle, DeploymentOptions, Handler)` but `Verticle` instance is created by invoking the default constructor of `verticleClass`.
public Future<String>	deployVerticle(Supplier<Verticle> verticleSupplier, DeploymentOptions options) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle, DeploymentOptions)` but `Verticle` instance is created by invoking the `verticleSupplier`.
public void	deployVerticle(Supplier<Verticle> verticleSupplier, DeploymentOptions options, Handler<AsyncResult<String>> completionHandler) Implements io.vertx.core.Vertx.deployVerticle. Like `deployVerticle(Verticle, DeploymentOptions, Handler)` but `Verticle` instance is created by invoking the `verticleSupplier`.
private Future<String>	deployVerticle(Callable<Verticle> verticleSupplier, DeploymentOptions options)
pack-priv void	duplicate(ContextBase src, ContextBase dst)
pack-priv void	endDispatch(ContextInternal the previous context thread to restore, might be `null` prev) End the emission of a context task.
private void	endDispatch2(ContextInternal prev)
public EventBus	eventBus() Implements io.vertx.core.Vertx.eventBus. Get the event bus object.
public Vertx	exceptionHandler(Handler<Throwable> handler)
public Handler<Throwable>	exceptionHandler() Implements io.vertx.core.Vertx.exceptionHandler.
pack-priv void	executeIsolated(Handler<Void> the task to execute task) Execute the `task` disabling the thread-local association for the duration of the execution.
public void	failDuringFailover(boolean fail) Implements io.vertx.core.impl.VertxInternal.failDuringFailover.
public synchronized void	failoverCompleteHandler(FailoverCompleteHandler failoverCompleteHandler) Implements io.vertx.core.impl.VertxInternal.failoverCompleteHandler.
public FileResolver	fileResolver() Implements io.vertx.core.impl.VertxInternal.fileResolver.
public FileSystem	fileSystem() Implements io.vertx.core.Vertx.fileSystem. Get the filesystem object.
public EventLoopGroup	getAcceptorEventLoopGroup() Implements io.vertx.core.impl.VertxInternal.getAcceptorEventLoopGroup.
public ClusterManager	getClusterManager() Implements io.vertx.core.impl.VertxInternal.getClusterManager.
public ContextInternal	getContext() Implements io.vertx.core.impl.VertxInternal.getContext. Get the current context
private ContextInternal	getContext(Thread current)
public Deployment	getDeployment(String deploymentID) Implements io.vertx.core.impl.VertxInternal.getDeployment.
public EventLoopGroup	getEventLoopGroup() Implements io.vertx.core.impl.VertxInternal.getEventLoopGroup.
protected FileSystem	Returns: The FileSystem implementation for the OS getFileSystem()
public WorkerPool	getInternalWorkerPool() Implements io.vertx.core.impl.VertxInternal.getInternalWorkerPool.
public Metrics	getMetrics() Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Returns the metrics implementation.
public ContextInternal	getOrCreateContext() Implements io.vertx.core.impl.VertxInternal.getOrCreateContext. Gets the current context, or creates one if there isn't one
private ContextInternal	getStickyContext()
public WorkerPool	getWorkerPool() Implements io.vertx.core.impl.VertxInternal.getWorkerPool.
public HAManager	haManager() Implements io.vertx.core.impl.VertxInternal.haManager.
public HttpClientBuilder	httpClientBuilder() Implements io.vertx.core.Vertx.httpClientBuilder. Provide a builder for `HttpClient`, it can be used to configure advanced HTTP client settings like a redirect handler or a connection handler.
pack-priv void	init()
pack-priv void	initClustered(VertxOptions options, Handler<AsyncResult<Vertx>> resultHandler)
private void	initializeHaManager(Promise<Void> initPromise)
public boolean	isClustered() Implements io.vertx.core.Vertx.isClustered. Is this Vert.x instance clustered?
public boolean	isKilled() Implements io.vertx.core.impl.VertxInternal.isKilled.
public boolean	isMetricsEnabled() Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled. Whether the metrics are enabled for this measured object
public boolean	isNativeTransportEnabled() Implements io.vertx.core.Vertx.isNativeTransportEnabled.
public boolean	isVirtualThreadAvailable() Implements io.vertx.core.impl.VertxInternal.isVirtualThreadAvailable.
public long	maxEventLoopExecTime() Implements io.vertx.core.impl.VertxInternal.maxEventLoopExecTime.
public TimeUnit	maxEventLoopExecTimeUnit() Implements io.vertx.core.impl.VertxInternal.maxEventLoopExecTimeUnit.
public VertxMetrics	metricsSPI() Implements io.vertx.core.impl.VertxInternal.metricsSPI.
public AddressResolverGroup<InetSocketAddress>	nettyAddressResolverGroup() Implements io.vertx.core.impl.VertxInternal.nettyAddressResolverGroup.
public EventLoopGroup	nettyEventLoopGroup() Implements io.vertx.core.Vertx.nettyEventLoopGroup. Return the Netty EventLoopGroup used by Vert.x
public TimeoutStream	periodicStream(long the initial delay in milliseconds initialDelay, long the delay in milliseconds, after which the timer will fire delay) Implements io.vertx.core.Vertx.periodicStream. References Deprecated `TimeoutStream` is deprecated or references (maybe indirectly) at least one deprecated element. Returns a periodic timer as a read stream.
public <T> PromiseInternal<T>	promise() Implements io.vertx.core.impl.VertxInternal.promise.
public <T> PromiseInternal<T>	promise(Handler<AsyncResult<T>> handler) Implements io.vertx.core.impl.VertxInternal.promise.
public void	registerVerticleFactory(VerticleFactory the factory to register factory) Implements io.vertx.core.Vertx.registerVerticleFactory. Register a `VerticleFactory` that can be used for deploying Verticles based on an identifier.
public void	removeCloseHook(Closeable hook) Implements io.vertx.core.impl.VertxInternal.removeCloseHook.
public void	resolveAddress(String the hostname to resolve hostname, Handler<AsyncResult<InetAddress>> the result handler resultHandler) Implements io.vertx.core.impl.VertxInternal.resolveAddress. Resolve an address (e.g. `vertx.io` into the first found A (IPv4) or AAAA (IPv6) record.
private CloseFuture	resolveCloseFuture()
public File	resolveFile(String fileName) Implements io.vertx.core.impl.VertxInternal.resolveFile.
public void	runOnContext(Handler<Void> - a handler representing the action to execute task) Implements io.vertx.core.Vertx.runOnContext. Puts the handler on the event queue for the current context so it will be run asynchronously ASAP after all preceeding events have been handled.
private long	scheduleTimeout(ContextInternal context, boolean periodic, long initialDelay, long delay, TimeUnit timeUnit, boolean addCloseHook, Handler<Long> handler)
public long	scheduleTimeout(ContextInternal context, boolean periodic, long delay, TimeUnit timeUnit, boolean addCloseHook, Handler<Long> handler)
public long	setPeriodic(long the initial delay in milliseconds initialDelay, long the delay in milliseconds, after which the timer will fire delay, Handler<Long> the handler that will be called with the timer ID when the timer fires handler) Implements io.vertx.core.Vertx.setPeriodic. Set a periodic timer to fire every `delay` milliseconds with initial delay, at which point `handler` will be called with the id of the timer.
public long	setTimer(long the delay in milliseconds, after which the timer will fire delay, Handler<Long> the handler that will be called with the timer ID when the timer fires handler) Implements io.vertx.core.Vertx.setTimer. Set a one-shot timer to fire after `delay` milliseconds, at which point `handler` will be called with the id of the timer.
public SharedData	sharedData() Implements io.vertx.core.Vertx.sharedData. Get the shared data object.
public Map<ServerID, HttpServerImpl>	sharedHttpServers() Implements io.vertx.core.impl.VertxInternal.sharedHttpServers.
public Map<ServerID, NetServerImpl>	sharedNetServers() Implements io.vertx.core.impl.VertxInternal.sharedNetServers.
public <S extends TCPServerBase> Map<ServerID, S>	sharedTCPServers(Class<S> type) Implements io.vertx.core.impl.VertxInternal.sharedTCPServers.
public void	simulateKill() Implements io.vertx.core.impl.VertxInternal.simulateKill.
private void	startEventBus(boolean haEnabled, Promise<Void> initPromise)
public Timer	timer(long the delay delay, TimeUnit the delay unit unit) Implements io.vertx.core.Vertx.timer. Create a timer task configured with the specified `delay`, when the timeout fires the timer future is succeeded, when the timeout is cancelled the timer future is failed with a `java.util.concurrent.CancellationException` instance.
public TimeoutStream	timerStream(long the delay in milliseconds, after which the timer will fire delay) Implements io.vertx.core.Vertx.timerStream. References Deprecated `TimeoutStream` is deprecated or references (maybe indirectly) at least one deprecated element. Returns a one-shot timer as a read stream.
public VertxTracer<I, O>	tracer() Implements io.vertx.core.impl.VertxInternal.tracer.
public Transport	transport() Implements io.vertx.core.impl.VertxInternal.transport.
public Throwable	unavailableNativeTransportCause() Implements io.vertx.core.Vertx.unavailableNativeTransportCause.
public Future<Void>	undeploy(String the deployment ID deploymentID) Implements io.vertx.core.Vertx.undeploy. Undeploy a verticle deployment.
public void	undeploy(String the deployment ID deploymentID, Handler<AsyncResult<Void>> a handler which will be notified when the undeployment is complete completionHandler) Implements io.vertx.core.Vertx.undeploy. Like `undeploy(String)` but the completionHandler will be notified when the undeployment is complete.
public void	unregisterVerticleFactory(VerticleFactory the factory to unregister factory) Implements io.vertx.core.Vertx.unregisterVerticleFactory. Unregister a `VerticleFactory`
public Set<VerticleFactory>	verticleFactories() Implements io.vertx.core.Vertx.verticleFactories. Return the Set of currently registered verticle factories.
private static ThreadFactory	virtualThreadFactory()
public WorkerPool	wrapWorkerPool(ExecutorService executor) Implements io.vertx.core.impl.VertxInternal.wrapWorkerPool.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

public Class VertxImpl

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary