| Modifier and Type | Method and Description |
|---|---|
static AmqpClient |
AmqpClient.create(Vertx vertx,
AmqpClientOptions options)
Creates a new instance of
AmqpClient with the given Vert.x instance and the given options. |
| Constructor and Description |
|---|
AmqpClientImpl(Vertx vertx,
AmqpClientOptions options,
boolean mustCloseVertxOnClose) |
| Modifier and Type | Method and Description |
|---|---|
static CircuitBreaker |
CircuitBreaker.create(String name,
Vertx vertx)
Creates a new instance of
CircuitBreaker, with default options. |
static CircuitBreaker |
CircuitBreaker.create(String name,
Vertx vertx,
CircuitBreakerOptions options)
Creates a new instance of
CircuitBreaker. |
static HystrixMetricHandler |
HystrixMetricHandler.create(Vertx vertx)
Creates the handler, using the default notification address.
|
static HystrixMetricHandler |
HystrixMetricHandler.create(Vertx vertx,
String address)
Creates the handler.
|
| Constructor and Description |
|---|
CircuitBreakerImpl(String name,
Vertx vertx,
CircuitBreakerOptions options) |
HystrixMetricEventStream(Vertx vertx,
String address) |
| Modifier and Type | Method and Description |
|---|---|
static ConfigRetriever |
ConfigRetriever.create(Vertx vertx)
Creates an instance of the default implementation of the
ConfigRetriever, using the default
settings (json file, system properties and environment variables). |
static ConfigRetriever |
ConfigRetriever.create(Vertx vertx,
ConfigRetrieverOptions options)
Creates an instance of the default implementation of the
ConfigRetriever. |
| Constructor and Description |
|---|
ConfigRetrieverImpl(Vertx vertx,
ConfigRetrieverOptions options) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
HttpConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
SystemPropertiesConfigStore.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
JsonConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
FileConfigtoreFactory.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
EventBusConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
EnvVariablesConfigStore.create(Vertx vertx,
JsonObject configuration) |
ConfigStore |
DirectoryConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
void |
PropertiesConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
void |
RawProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
void |
JsonProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
| Constructor and Description |
|---|
DirectoryConfigStore(Vertx vertx,
JsonObject configuration) |
EventBusConfigStore(Vertx vertx,
String address) |
FileConfigStore(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
ConfigMapStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Constructor and Description |
|---|
ConfigMapStore(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
ConfigStoreFactory.create(Vertx vertx,
JsonObject configuration)
Creates an instance of the
ConfigStore. |
void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Transforms the given
input into a JsonObject. |
| Constructor and Description |
|---|
FileSet(Vertx vertx,
File root,
JsonObject set)
Creates a new
FileSet from a json object. |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
VaultConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Constructor and Description |
|---|
VaultConfigStore(Vertx vertx,
JsonObject config)
Creates an instance of
VaultConfigStore. |
| Constructor and Description |
|---|
SlimVaultClient(Vertx vertx,
JsonObject configuration)
Creates an instance of
SlimVaultClient. |
| Modifier and Type | Method and Description |
|---|---|
void |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
Starter.vertx
Deprecated.
|
protected Vertx |
AbstractVerticle.vertx
Reference to the Vert.x instance that deployed this verticle
|
| Modifier and Type | Method and Description |
|---|---|
Vertx |
Vertx.exceptionHandler(Handler<Throwable> handler)
Set a default exception handler for
Context, set on Context.exceptionHandler(Handler) at creation. |
Vertx |
Verticle.getVertx()
Get a reference to the Vert.x instance that deployed this verticle
|
Vertx |
AbstractVerticle.getVertx()
Get the Vert.x instance
|
Vertx |
Context.owner() |
static Vertx |
Vertx.vertx()
Creates a non clustered instance using default options.
|
static Vertx |
Vertx.vertx(VertxOptions options)
Creates a non clustered instance using the specified options
|
| Modifier and Type | Method and Description |
|---|---|
void |
Launcher.afterStartingVertx(Vertx vertx)
Hook for sub-classes of
Launcher after the vertx instance is started. |
void |
Launcher.beforeStoppingVertx(Vertx vertx) |
void |
Launcher.handleDeployFailed(Vertx vertx,
String mainVerticle,
DeploymentOptions deploymentOptions,
Throwable cause)
A deployment failure has been encountered.
|
void |
Verticle.init(Vertx vertx,
Context context)
Initialise the verticle with the Vert.x instance and the context.
|
void |
AbstractVerticle.init(Vertx vertx,
Context context)
Initialise the verticle.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
Vertx.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a clustered instance using the specified options.
|
| Constructor and Description |
|---|
HandlerRegistration(Vertx vertx,
EventBusMetrics metrics,
EventBusImpl eventBus,
String address,
String repliedAddress,
boolean localOnly,
Handler<AsyncResult<Message<T>>> asyncResultHandler,
long timeout) |
MessageProducerImpl(Vertx vertx,
String address,
boolean send,
DeliveryOptions options) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
VertxInternal
This interface provides services for vert.x core internal use only
It is not part of the public API and should not be used by
developers creating vert.x applications
|
| Modifier and Type | Class and Description |
|---|---|
class |
VertxImpl |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
VertxImpl.exceptionHandler(Handler<Throwable> handler) |
Vertx |
WorkerExecutorInternal.vertx() |
Vertx |
VertxFactoryImpl.vertx() |
Vertx |
VertxFactoryImpl.vertx(VertxOptions options) |
Vertx |
VertxFactoryImpl.vertx(VertxOptions options,
Transport transport) |
| Modifier and Type | Method and Description |
|---|---|
void |
VertxFactoryImpl.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
void |
VertxFactoryImpl.clusteredVertx(VertxOptions options,
Transport transport,
Handler<AsyncResult<Vertx>> resultHandler) |
| Constructor and Description |
|---|
AddressResolver(Vertx vertx,
AddressResolverOptions options) |
| Modifier and Type | Method and Description |
|---|---|
void |
VertxLifecycleHooks.afterStartingVertx(Vertx vertx)
Hook for sub-classes of the
Launcher class after the vertx instance is started. |
void |
VertxLifecycleHooks.beforeStoppingVertx(Vertx vertx)
|
void |
VertxLifecycleHooks.handleDeployFailed(Vertx vertx,
String mainVerticle,
DeploymentOptions deploymentOptions,
Throwable cause)
A deployment failure has been encountered.
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
BareCommand.vertx |
| Modifier and Type | Method and Description |
|---|---|
protected Vertx |
ClasspathHandler.create(VertxOptions options)
Creates a new non-clustered vert.x instance.
|
protected Vertx |
BareCommand.startVertx()
Starts the vert.x instance.
|
Vertx |
BareCommand.vertx() |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
BareCommand.addShutdownHook(Vertx vertx,
Logger log,
Runnable action)
Registers a shutdown hook closing the given vert.x instance when the JVM is terminating.
|
protected void |
BareCommand.afterStartingVertx(Vertx instance)
Hook called after starting vert.x.
|
protected void |
RunCommand.beforeStoppingVertx(Vertx vertx) |
void |
ClasspathHandler.deploy(String verticle,
Vertx vertx,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Deploys the given verticle using the given deployment options.
|
void |
VertxIsolatedDeployer.deploy(String verticle,
Vertx vertx,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Deploys the given verticle.
|
static Runnable |
BareCommand.getTerminationRunnable(Vertx vertx,
Logger log,
Runnable action)
Gets the termination runnable used to close the Vert.x instance.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
ClasspathHandler.create(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a new clustered vert.x instance.
|
| Modifier and Type | Method and Description |
|---|---|
default KeyManagerFactory |
KeyCertOptions.getKeyManagerFactory(Vertx vertx)
Create and return the key manager factory for these options.
|
default TrustManagerFactory |
TrustOptions.getTrustManagerFactory(Vertx vertx)
Create and return the trust manager factory for these options.
|
default Function<String,X509KeyManager> |
KeyCertOptions.keyManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to
X509KeyManager instance. |
default Function<String,TrustManager[]> |
TrustOptions.trustManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to a
TrustManagerFactory instance. |
| Constructor and Description |
|---|
LocalAsyncMapImpl(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
VertxFactory.vertx() |
Vertx |
VertxFactory.vertx(VertxOptions options) |
Vertx |
VertxFactory.vertx(VertxOptions options,
Transport transport) |
| Modifier and Type | Method and Description |
|---|---|
default void |
VerticleFactory.init(Vertx vertx)
Initialise the factory
|
| Modifier and Type | Method and Description |
|---|---|
void |
VertxFactory.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
void |
VertxFactory.clusteredVertx(VertxOptions options,
Transport transport,
Handler<AsyncResult<Vertx>> resultHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterManager.setVertx(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
default void |
VertxMetrics.vertxCreated(Vertx vertx)
Callback to signal when the Vertx instance is fully initialized.
|
| Modifier and Type | Method and Description |
|---|---|
static ResolverProvider |
ResolverProvider.factory(Vertx vertx,
AddressResolverOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static void |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions,
Handler<AsyncResult<DB2Connection>> handler)
Create a connection to DB2 server with the given
connectOptions. |
static void |
DB2Connection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<DB2Connection>> handler)
Like
DB2Connection.connect(Vertx, DB2ConnectOptions, Handler) with options build
from connectionUri. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
DB2ConnectOptions connectOptions,
PoolOptions poolOptions)
Like
DB2Pool.pool(DB2ConnectOptions, PoolOptions) with a specific
Vertx instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri)
Like
DB2Pool.pool(Vertx, String,PoolOptions) with a default
poolOptions.. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
DB2Pool.pool(Vertx, DB2ConnectOptions, PoolOptions) with
connectOptions build from connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
static void |
DB2ConnectionImpl.connect(Vertx vertx,
DB2ConnectOptions options,
Handler<AsyncResult<DB2Connection>> handler) |
| Modifier and Type | Method and Description |
|---|---|
Pool |
DB2Driver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
| Modifier and Type | Method and Description |
|---|---|
AuthProvider |
AuthOptions.createProvider(Vertx vertx)
Deprecated.
Create the suitable provider for this option.
|
static VertxContextPRNG |
VertxContextPRNG.current(Vertx vertx)
Get or create a secure non blocking random number generator using the current vert.x instance.
|
| Constructor and Description |
|---|
PRNG(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
static HtdigestAuth |
HtdigestAuth.create(Vertx vertx)
Creates an instance of HtdigestAuth.
|
static HtdigestAuth |
HtdigestAuth.create(Vertx vertx,
String htfile)
Creates an instance of HtdigestAuth by using the given htfile file.
|
| Constructor and Description |
|---|
HtdigestAuthImpl(Vertx vertx,
String htdigestFile)
Creates a new instance
|
| Modifier and Type | Method and Description |
|---|---|
static HtpasswdAuth |
HtpasswdAuth.create(Vertx vertx) |
static HtpasswdAuth |
HtpasswdAuth.create(Vertx vertx,
HtpasswdAuthOptions htpasswdAuthOptions) |
AuthProvider |
HtpasswdAuthOptions.createProvider(Vertx vertx) |
| Constructor and Description |
|---|
HtpasswdAuthImpl(Vertx vertx,
HtpasswdAuthOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JsonObject config)
Deprecated.
|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JWTAuthOptions config)
Create a JWT auth provider
|
| Constructor and Description |
|---|
JWTAuthProviderImpl(Vertx vertx,
JWTAuthOptions config) |
| Modifier and Type | Method and Description |
|---|---|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow)
Deprecated.
the flow configuration should be passed in the config object
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow,
OAuth2ClientOptions config)
Deprecated.
the flow configuration should be passed in the config object
|
static OAuth2Auth |
OAuth2Auth.createKeycloak(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Deprecated.
You should use the provider helper
KeycloakAuth instead.
Create a OAuth2 auth provider |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
OAuth2AuthProviderImpl.getVertx() |
| Modifier and Type | Method and Description |
|---|---|
static void |
OAuth2API.fetch(Vertx vertx,
OAuth2ClientOptions config,
HttpMethod method,
String path,
JsonObject headers,
Buffer payload,
Handler<AsyncResult<OAuth2Response>> callback) |
static HttpClientRequest |
OAuth2API.makeRequest(Vertx vertx,
HttpClientOptions options,
HttpMethod method,
String uri,
Handler<AsyncResult<OAuth2Response>> callback) |
| Constructor and Description |
|---|
OAuth2AuthProviderImpl(Vertx vertx,
OAuth2ClientOptions config) |
| Modifier and Type | Method and Description |
|---|---|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Github
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Foursquare
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Heroku
|
static OAuth2Auth |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Mailchimp
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for SoundCloud
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Stripe
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Twitter
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Github
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Foursquare
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Heroku
|
static OAuth2Auth |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Mailchimp
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for SoundCloud
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Stripe
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Twitter
|
static OAuth2Auth |
CloudFoundryAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String uuaURL)
Create a OAuth2Auth provider for CloudFoundry UAA
|
static OAuth2Auth |
AzureADAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String guid)
Create a OAuth2Auth provider for Microsoft Azure Active Directory
|
static OAuth2Auth |
ShopifyAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String shop)
Create a OAuth2Auth provider for Shopify
|
static OAuth2Auth |
CloudFoundryAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String uuaURL,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for CloudFoundry UAA
|
static OAuth2Auth |
AzureADAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String guid,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Microsoft Azure Active Directory
|
static OAuth2Auth |
ShopifyAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String shop,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Shopify
|
static void |
GoogleAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AzureADAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
KeycloakAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
SalesforceAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
| Modifier and Type | Method and Description |
|---|---|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx)
|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx,
boolean detailed)
Creates a ready-to-use Vert.x cluster
HealthChecks procedure. |
void |
InfinispanClusterManager.setVertx(Vertx vertx) |
| Constructor and Description |
|---|
InfinispanAsyncMapImpl(Vertx vertx,
org.infinispan.Cache<Object,Object> cache) |
InfinispanAsyncMultiMap(Vertx vertx,
org.infinispan.multimap.impl.EmbeddedMultimapCache<Object,Object> multimapCache) |
InfinispanCounter(Vertx vertx,
org.infinispan.counter.api.SyncStrongCounter strongCounter) |
| Modifier and Type | Method and Description |
|---|---|
static HealthChecks |
HealthChecks.create(Vertx vertx)
Creates a new instance of the default implementation of
HealthChecks. |
static HealthCheckHandler |
HealthCheckHandler.create(Vertx vertx)
Creates an instance of the default implementation of the
HealthCheckHandler. |
static HealthCheckHandler |
HealthCheckHandler.create(Vertx vertx,
AuthProvider provider)
Creates an instance of the default implementation of the
HealthCheckHandler. |
| Constructor and Description |
|---|
HealthCheckHandlerImpl(Vertx vertx,
AuthProvider provider) |
HealthChecksImpl(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
static JDBCClient |
JDBCClient.create(Vertx vertx,
DataSource dataSource)
Create a client using a pre-existing data source
|
static JDBCClient |
JDBCClient.create(Vertx vertx,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
static JDBCClient |
JDBCClient.createNonShared(Vertx vertx,
JsonObject config)
Deprecated.
use
JDBCClient.create(Vertx, JsonObject) instead |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config)
Like
JDBCClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a JDBC client which shares its data source with any other JDBC clients created with the same
data source name
|
| Constructor and Description |
|---|
JDBCClientImpl(Vertx vertx,
DataSource dataSource)
Create client with specific datasource.
|
JDBCClientImpl(Vertx vertx,
JsonObject config,
String datasourceName)
Create client with shared datasource.
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
AbstractJDBCAction.vertx |
| Modifier and Type | Method and Description |
|---|---|
static MailClient |
MailClient.create(Vertx vertx,
MailConfig config)
Create a non shared instance of the mail client.
|
static MailClient |
MailClient.createNonShared(Vertx vertx,
MailConfig config)
Deprecated.
use
MailClient.create(Vertx, MailConfig) instead |
static MailClient |
MailClient.createShared(Vertx vertx,
MailConfig config)
Like
MailClient.createShared(io.vertx.core.Vertx, MailConfig, String) but with the default pool name |
static MailClient |
MailClient.createShared(Vertx vertx,
MailConfig config,
String poolName)
Create a Mail client which shares its connection pool with any other Mail clients created with the same
pool name
|
| Constructor and Description |
|---|
MailClientImpl(Vertx vertx,
MailConfig config,
String poolName) |
| Modifier and Type | Method and Description |
|---|---|
static MongoClient |
MongoClient.create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
static MongoClient |
MongoClient.createNonShared(Vertx vertx,
JsonObject config)
Deprecated.
use
MongoClient.create(Vertx, JsonObject) instead |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
| Constructor and Description |
|---|
MongoClientImpl(Vertx vertx,
JsonObject config,
String dataSourceName) |
| Modifier and Type | Method and Description |
|---|---|
void |
TestCase.awaitSuccess(Vertx vertx)
Assert the test case passes and block until it is executed.
|
void |
TestCase.awaitSuccess(Vertx vertx,
long timeout,
TimeUnit unit)
Assert the test case passes and block until it is executed.
|
TestCompletion |
TestSuite.run(Vertx vertx)
Run the testsuite with the default options and the specified
vertx instance.
The test suite will be executed on the event loop provided by the vertx argument. |
TestCompletion |
TestSuite.run(Vertx vertx,
TestOptions options)
Run the testsuite with the specified
options and the specified vertx instance.
The test suite will be executed on the event loop provided by the vertx argument when
TestOptions.setUseEventLoop(Boolean) is not set to false. |
| Modifier and Type | Method and Description |
|---|---|
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
Handler<TestSuiteReport> reporter) |
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
ReportingOptions options)
Create a message handler reporting with the specified options.
|
| Constructor and Description |
|---|
EventBusCollectorImpl(Vertx vertx,
Handler<TestSuiteReport> reporter) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
TestSuiteRunner.getVertx() |
| Modifier and Type | Method and Description |
|---|---|
void |
TestCaseImpl.awaitSuccess(Vertx vertx) |
void |
TestCaseImpl.awaitSuccess(Vertx vertx,
long timeout,
TimeUnit unit) |
void |
TestCommand.deploy(String verticle,
Vertx vertx,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler) |
TestCompletion |
TestSuiteImpl.run(Vertx vertx) |
TestCompletion |
TestSuiteImpl.run(Vertx vertx,
TestOptions options) |
TestSuiteRunner |
TestSuiteRunner.setVertx(Vertx vertx)
Set a vertx instance of the runner.
|
| Modifier and Type | Method and Description |
|---|---|
Vertx |
RunTestOnContext.vertx()
Retrieves the current Vert.x instance, this value varies according to the test life cycle.
|
| Constructor and Description |
|---|
RunTestOnContext(Supplier<Vertx> createVertx)
Create a new rule with supplier for creating a Vert.x instance.
|
RunTestOnContext(Supplier<Vertx> createVertx,
BiConsumer<Vertx,Consumer<Void>> closeVertx)
Create a new rule with supplier/consumer for creating/closing a Vert.x instance.
|
RunTestOnContext(Supplier<Vertx> createVertx,
BiConsumer<Vertx,Consumer<Void>> closeVertx)
Create a new rule with supplier/consumer for creating/closing a Vert.x instance.
|
| Modifier and Type | Method and Description |
|---|---|
Reporter |
ReporterFactory.reporter(Vertx vertx,
ReportOptions options) |
static Reporter<?> |
Reporter.reporter(Vertx vertx,
ReportOptions options) |
| Modifier and Type | Method and Description |
|---|---|
Reporter |
DefaultReporterFactory.reporter(Vertx vertx,
ReportOptions options) |
| Constructor and Description |
|---|
EventBusReporter(Vertx vertx,
String address) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
RoutingContext.vertx() |
| Modifier and Type | Method and Description |
|---|---|
static Router |
Router.router(Vertx vertx)
Create a router
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
BaseRouterFactory.vertx |
| Constructor and Description |
|---|
BaseRouterFactory(Vertx vertx,
Specification spec) |
BaseRouterFactory(Vertx vertx,
Specification spec,
RouterFactoryOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
| Constructor and Description |
|---|
OpenAPI3RouterFactoryImpl(Vertx vertx,
io.swagger.v3.oas.models.OpenAPI spec,
io.swagger.v3.parser.ResolverCache refsCache) |
| Modifier and Type | Method and Description |
|---|---|
static WebClient |
WebClient.create(Vertx vertx)
Create a web client using the provided
vertx instance and default options. |
static WebClient |
WebClient.create(Vertx vertx,
WebClientOptions options)
Create a web client using the provided
vertx instance. |
| Modifier and Type | Method and Description |
|---|---|
static SockJSHandler |
SockJSHandler.create(Vertx vertx)
Create a SockJS handler
|
static SockJSHandler |
SockJSHandler.create(Vertx vertx,
SockJSHandlerOptions options)
Create a SockJS handler
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
SockJSSocketBase.vertx |
| Constructor and Description |
|---|
EventBusBridgeImpl(Vertx vertx,
SockJSBridgeOptions options,
Handler<BridgeEvent> bridgeEventHandler) |
SockJSHandlerImpl(Vertx vertx,
SockJSHandlerOptions options) |
SockJSSocketBase(Vertx vertx,
Session webSession,
User webUser) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
RoutingContextImpl.vertx() |
Vertx |
RoutingContextWrapper.vertx() |
Vertx |
RoutingContextDecorator.vertx() |
| Modifier and Type | Method and Description |
|---|---|
static String |
Utils.readFileToString(Vertx vertx,
String resource) |
static String |
Utils.readFileToString(Vertx vertx,
String resource,
Charset charset) |
| Constructor and Description |
|---|
RouterImpl(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx)
Create a session store
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx)
Create a session store
|
static SessionStore |
SessionStore.create(Vertx vertx)
Create a Session store given a backend and configuration JSON.
|
static SessionStore |
SessionStore.create(Vertx vertx,
JsonObject options)
Create a Session store given a backend and configuration JSON.
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
long retryTimeout)
Create a session store.
The retry timeout value, configures how long the session handler will retry to get a session from the store
when it is not found.
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
String sessionMapName,
long retryTimeout)
Create a session store.
The retry timeout value, configures how long the session handler will retry to get a session from the store
when it is not found.
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName,
long reaperInterval)
Create a session store
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
LocalSessionStoreImpl.vertx |
| Modifier and Type | Method and Description |
|---|---|
SessionStore |
LocalSessionStoreImpl.init(Vertx vertx,
JsonObject options) |
SessionStore |
ClusteredSessionStoreImpl.init(Vertx vertx,
JsonObject options) |
| Modifier and Type | Method and Description |
|---|---|
static FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
| Modifier and Type | Method and Description |
|---|---|
static FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
| Constructor and Description |
|---|
FreeMarkerTemplateEngineImpl(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
| Constructor and Description |
|---|
HandlebarsTemplateEngineImpl(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
static VertxChannelBuilder |
VertxChannelBuilder.forAddress(Vertx vertx,
SocketAddress address) |
static VertxServerBuilder |
VertxServerBuilder.forAddress(Vertx vertx,
SocketAddress address) |
static VertxChannelBuilder |
VertxChannelBuilder.forAddress(Vertx vertx,
String host,
int port) |
static VertxServerBuilder |
VertxServerBuilder.forAddress(Vertx vertx,
String host,
int port) |
static VertxServerBuilder |
VertxServerBuilder.forPort(Vertx vertx,
int port) |
static VertxChannelBuilder |
VertxChannelBuilder.forTarget(Vertx vertx,
String target) |
static io.grpc.ServerInterceptor |
BlockingServerInterceptor.wrap(Vertx vertx,
io.grpc.ServerInterceptor interceptor) |
| Modifier and Type | Method and Description |
|---|---|
static Vertx |
VertxExtension.retrieveVertx(Executable declaringExecutable,
org.junit.jupiter.api.extension.ExtensionContext context) |
| Modifier and Type | Method and Description |
|---|---|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
org.apache.kafka.clients.admin.AdminClient adminClient)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
Properties config)
Create a new KafkaAdminClient instance
|
| Constructor and Description |
|---|
KafkaAdminClientImpl(Vertx vertx,
org.apache.kafka.clients.admin.AdminClient adminClient) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Create a new KafkaConsumer instance from a native
Consumer. |
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config)
Create a new KafkaReadStream instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaConsumer instance
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaProducer instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaProducer instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaProducer instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
org.apache.kafka.clients.producer.Producer<K,V> producer)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
org.apache.kafka.clients.producer.Producer<K,V> producer)
Create a new KafkaProducer instance from a native
Producer. |
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Properties config)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Properties config)
Create a new KafkaProducer instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaProducer instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaProducer instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Map<String,String> config)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Map<String,String> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Properties config)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Properties config,
Class<K> keyType,
Class<V> valueType)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
Properties config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaWriteStreamImpl<K,V> |
KafkaWriteStreamImpl.create(Vertx vertx,
Map<String,Object> config) |
static <K,V> KafkaWriteStreamImpl<K,V> |
KafkaWriteStreamImpl.create(Vertx vertx,
Map<String,Object> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
static <K,V> KafkaWriteStreamImpl<K,V> |
KafkaWriteStreamImpl.create(Vertx vertx,
Properties config) |
static <K,V> KafkaWriteStreamImpl<K,V> |
KafkaWriteStreamImpl.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Map<String,String> config) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Map<String,String> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Properties config) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Properties config,
Class<K> keyType,
Class<V> valueType) |
static <K,V> KafkaProducer<K,V> |
KafkaProducerImpl.createShared(Vertx vertx,
String name,
Properties config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer) |
| Modifier and Type | Method and Description |
|---|---|
static MqttClient |
MqttClient.create(Vertx vertx)
Return an MQTT client instance using the default options
|
static MqttServer |
MqttServer.create(Vertx vertx)
Return an MQTT server instance using default options
|
static MqttClient |
MqttClient.create(Vertx vertx,
MqttClientOptions options)
Return an MQTT client instance
|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
| Constructor and Description |
|---|
MqttClientImpl(Vertx vertx,
MqttClientOptions options)
Constructor
|
MqttServerImpl(Vertx vertx,
MqttServerOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static void |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions,
Handler<AsyncResult<MySQLConnection>> handler)
Create a connection to MySQL server with the given
connectOptions. |
static void |
MySQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MySQLConnection>> handler)
Like
MySQLConnection.connect(Vertx, MySQLConnectOptions, Handler) with options build from connectionUri. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
MySQLConnectOptions connectOptions,
PoolOptions poolOptions)
Like
MySQLPool.pool(MySQLConnectOptions, PoolOptions) with a specific Vertx instance. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri)
Like
MySQLPool.pool(Vertx, String,PoolOptions) with a default poolOptions.. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
MySQLPool.pool(Vertx, MySQLConnectOptions, PoolOptions) with connectOptions build from connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
static void |
MySQLConnectionImpl.connect(Vertx vertx,
MySQLConnectOptions options,
Handler<AsyncResult<MySQLConnection>> handler) |
| Modifier and Type | Method and Description |
|---|---|
Pool |
MySQLDriver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
| Modifier and Type | Method and Description |
|---|---|
static void |
PgConnection.connect(Vertx vertx,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from the environment variables. |
static void |
PgConnection.connect(Vertx vertx,
PgConnectOptions options,
Handler<AsyncResult<PgConnection>> handler)
Connects to the database and returns the connection if that succeeds.
|
static void |
PgConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from connectionUri. |
static PgPool |
PgPool.pool(Vertx vertx,
PgConnectOptions connectOptions,
PoolOptions poolOptions)
Like
PgPool.pool(PgConnectOptions, PoolOptions) with a specific Vertx instance. |
static PgPool |
PgPool.pool(Vertx vertx,
PoolOptions poolOptions)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with connectOptions build from the environment variables. |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri)
Like
PgPool.pool(Vertx, String,PoolOptions) with a default poolOptions. |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with connectOptions build from connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
static void |
PgConnectionImpl.connect(Vertx vertx,
PgConnectOptions options,
Handler<AsyncResult<PgConnection>> handler) |
| Constructor and Description |
|---|
PgSubscriberImpl(Vertx vertx,
PgConnectOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static PgSubscriber |
PgSubscriber.subscriber(Vertx vertx,
PgConnectOptions options)
Create a subscriber.
|
| Modifier and Type | Method and Description |
|---|---|
Pool |
PgDriver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
| Modifier and Type | Method and Description |
|---|---|
static ProtonClient |
ProtonClient.create(Vertx vertx)
Create a ProtonClient instance with the given Vertx instance.
|
static ProtonServer |
ProtonServer.create(Vertx vertx)
Create a ProtonServer instance with the given Vertx instance.
|
static ProtonServer |
ProtonServer.create(Vertx vertx,
ProtonServerOptions options)
Create a ProtonServer instance with the given Vertx instance and options.
|
| Constructor and Description |
|---|
ProtonClientImpl(Vertx vertx) |
ProtonServerImpl(Vertx vertx) |
ProtonServerImpl(Vertx vertx,
ProtonServerOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static Scheduler |
RxHelper.blockingScheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions can be blocking, they are not executed
on Vertx event loop. |
static Scheduler |
RxHelper.blockingScheduler(Vertx vertx,
boolean ordered)
Create a scheduler for a
Vertx object, actions can be blocking, they are not executed
on Vertx event loop. |
static Scheduler |
RxHelper.scheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions are executed on the event loop. |
| Constructor and Description |
|---|
ContextScheduler(Vertx vertx,
boolean blocking) |
ContextScheduler(Vertx vertx,
boolean blocking,
boolean ordered) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
Vertx.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Vertx |
Vertx.newInstance(Vertx arg) |
| Constructor and Description |
|---|
Vertx(Vertx delegate) |
| Modifier and Type | Method and Description |
|---|---|
static RedisClient |
RedisClient.create(Vertx vertx)
Deprecated.
|
static RedisClient |
RedisClient.create(Vertx vertx,
JsonObject config)
Deprecated.
|
static RedisClient |
RedisClient.create(Vertx vertx,
RedisOptions config)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static Redis |
Redis.createClient(Vertx vertx)
Create a new redis client using the default client options.
|
static Redis |
Redis.createClient(Vertx vertx,
RedisOptions options)
Create a new redis client using the given client options.
|
static Redis |
Redis.createClient(Vertx vertx,
String connectionString)
Create a new redis client using the default client options.
|
| Constructor and Description |
|---|
RedisClient(Vertx vertx,
RedisOptions options) |
RedisClusterClient(Vertx vertx,
RedisOptions options) |
RedisConnectionImpl(Vertx vertx,
ContextInternal context,
ConnectionListener<RedisConnection> connectionListener,
NetSocket netSocket,
RedisOptions options) |
RedisSentinelClient(Vertx vertx,
RedisOptions options) |
| Constructor and Description |
|---|
RedisClientImpl(Vertx vertx,
RedisOptions options)
Deprecated.
|
RedisSentinelClientImpl(Vertx vertx,
RedisOptions options)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static RedisSentinel |
RedisSentinel.create(Vertx vertx)
Deprecated.
|
static RedisSentinel |
RedisSentinel.create(Vertx vertx,
JsonObject config)
Deprecated.
|
static RedisSentinel |
RedisSentinel.create(Vertx vertx,
RedisOptions options)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static Scheduler |
RxHelper.blockingScheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions can be blocking, they are not executed
on Vertx event loop. |
static Scheduler |
RxHelper.blockingScheduler(Vertx vertx,
boolean ordered)
Create a scheduler for a
Vertx object, actions can be blocking, they are not executed
on Vertx event loop. |
static Scheduler |
RxHelper.scheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions are executed on the event loop. |
static RxJavaSchedulersHook |
RxHelper.schedulerHook(Vertx vertx)
Create a scheduler hook for a
Vertx object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler. |
| Constructor and Description |
|---|
ContextScheduler(Vertx vertx,
boolean blocking) |
ContextScheduler(Vertx vertx,
boolean blocking,
boolean ordered) |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
Vertx.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Vertx |
Vertx.newInstance(Vertx arg) |
| Constructor and Description |
|---|
Vertx(Vertx delegate) |
| Modifier and Type | Method and Description |
|---|---|
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
Handler<ServiceDiscovery> completionHandler)
Deprecated.
this will be removed in Vert.x 4, instead use
ServiceDiscovery.create(Vertx) |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options,
Handler<ServiceDiscovery> completionHandler)
Deprecated.
this will be removed in Vert.x 4, instead use
ServiceDiscovery.create(Vertx, ServiceDiscoveryOptions) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultServiceDiscoveryBackend.init(Vertx vertx,
JsonObject config) |
| Constructor and Description |
|---|
DiscoveryImpl(Vertx vertx,
ServiceDiscoveryOptions options) |
| Modifier and Type | Method and Description |
|---|---|
void |
KubernetesServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
| Modifier and Type | Method and Description |
|---|---|
ServiceReference |
ServiceType.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration)
Gets the `service` for the given record.
|
void |
ServiceDiscoveryBackend.init(Vertx vertx,
JsonObject config)
Initializes the backend.
|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
| Modifier and Type | Field and Description |
|---|---|
protected Vertx |
AbstractServiceReference.vertx |
| Constructor and Description |
|---|
AbstractServiceReference(Vertx vertx,
ServiceDiscovery discovery,
Record record)
Creates a new instance of
AbstractServiceReference. |
| Modifier and Type | Method and Description |
|---|---|
ServiceReference |
EventBusServiceImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
ServiceReference |
HttpEndpointImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
ServiceReference |
MessageSourceImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
ServiceReference |
JDBCDataSourceImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
ServiceReference |
MongoDataSourceImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
ServiceReference |
RedisDataSourceImpl.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address)
Deprecated.
use instead
ServiceProxyBuilder |
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address,
DeliveryOptions options)
Deprecated.
use instead
ServiceProxyBuilder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
| Constructor and Description |
|---|
ServiceBinder(Vertx vertx)
Creates a factory.
|
ServiceProxyBuilder(Vertx vertx)
Creates a builder.
|
| Modifier and Type | Method and Description |
|---|---|
static Pool |
Pool.pool(Vertx vertx,
SqlConnectOptions connectOptions,
PoolOptions poolOptions)
Create a connection pool to the database configured with the given
connectOptions and poolOptions. |
| Modifier and Type | Method and Description |
|---|---|
Pool |
Driver.createPool(Vertx vertx,
SqlConnectOptions connectOptions,
PoolOptions poolOptions)
Create a connection pool to the database configured with the given
connectOptions and poolOptions. |
Copyright © 2020. All rights reserved.