| 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. |
| Modifier and Type | Method and Description |
|---|---|
static CamelBridge |
CamelBridge.create(Vertx vertx,
CamelBridgeOptions bridgeOptions)
Creates a bridge between Camel endpoints and Vert.x
|
| Modifier and Type | Method and Description |
|---|---|
static CassandraClient |
CassandraClient.create(Vertx vertx)
Like
CassandraClient.create(Vertx, CassandraClientOptions) with default options. |
static CassandraClient |
CassandraClient.create(Vertx vertx,
CassandraClientOptions options)
Create a Cassandra client which maintains its own driver session.
|
static CassandraClient |
CassandraClient.createShared(Vertx vertx)
Like
CassandraClient.createShared(Vertx, String, CassandraClientOptions) with default options and client name. |
static CassandraClient |
CassandraClient.createShared(Vertx vertx,
CassandraClientOptions options)
Like
CassandraClient.createShared(Vertx, String, CassandraClientOptions) with default client name. |
static CassandraClient |
CassandraClient.createShared(Vertx vertx,
String clientName)
Like
CassandraClient.createShared(Vertx, String, CassandraClientOptions) with default options. |
static CassandraClient |
CassandraClient.createShared(Vertx vertx,
String clientName,
CassandraClientOptions options)
Create a Cassandra client that shares its driver session with any other client having the same name.
|
| 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.
|
| 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. |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
ConsulConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
GitConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Constructor and Description |
|---|
GitConfigStore(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
Future<JsonObject> |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
| 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 |
RedisConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Constructor and Description |
|---|
RedisConfigStore(Vertx vertx,
JsonObject config) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
ConfigStoreFactory.create(Vertx vertx,
JsonObject configuration)
Creates an instance of the
ConfigStore. |
default Future<JsonObject> |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input)
Transforms the given
input into a JsonObject. |
default void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Deprecated.
implement
ConfigProcessor.process(Vertx, JsonObject, Buffer) instead |
| 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 |
SpringConfigServerStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| 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 |
|---|---|
Future<JsonObject> |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
| Modifier and Type | Method and Description |
|---|---|
ConfigStore |
ZookeeperConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
| Constructor and Description |
|---|
ZookeeperConfigStore(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Field and Description |
|---|---|
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 |
|---|---|
static Future<Vertx> |
Vertx.clusteredVertx(VertxOptions options)
Same as
clusteredVertx(VertxOptions, Handler) but with an handler called when the operation completes |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
KeyManagerFactory |
KeyStoreOptionsBase.getKeyManagerFactory(Vertx vertx) |
KeyManagerFactory |
KeyCertOptions.getKeyManagerFactory(Vertx vertx)
Create and return the key manager factory for these options.
|
KeyManagerFactory |
PemKeyCertOptions.getKeyManagerFactory(Vertx vertx) |
TrustManagerFactory |
KeyStoreOptionsBase.getTrustManagerFactory(Vertx vertx) |
TrustManagerFactory |
TrustOptions.getTrustManagerFactory(Vertx vertx)
Create and return the trust manager factory for these options.
|
TrustManagerFactory |
PemTrustOptions.getTrustManagerFactory(Vertx vertx) |
java.util.function.Function<String,X509KeyManager> |
KeyStoreOptionsBase.keyManagerMapper(Vertx vertx) |
java.util.function.Function<String,X509KeyManager> |
KeyCertOptions.keyManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to
X509KeyManager instance. |
java.util.function.Function<String,X509KeyManager> |
PemKeyCertOptions.keyManagerMapper(Vertx vertx) |
KeyStore |
KeyStoreOptionsBase.loadKeyStore(Vertx vertx)
Load and return a Java keystore.
|
KeyStore |
PemKeyCertOptions.loadKeyStore(Vertx vertx)
Load and return a Java keystore.
|
KeyStore |
PemTrustOptions.loadKeyStore(Vertx vertx)
Load and return a Java keystore.
|
java.util.function.Function<String,TrustManager[]> |
KeyStoreOptionsBase.trustManagerMapper(Vertx vertx) |
java.util.function.Function<String,TrustManager[]> |
TrustOptions.trustManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to a
TrustManagerFactory instance. |
java.util.function.Function<String,TrustManager[]> |
PemTrustOptions.trustManagerMapper(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
default void |
VerticleFactory.init(Vertx vertx)
Initialise the factory
|
| Modifier and Type | Method and Description |
|---|---|
void |
NodeSelector.init(Vertx vertx,
ClusterManager clusterManager)
Invoked before the
vertx instance tries to join the cluster. |
void |
ClusterManager.init(Vertx vertx,
NodeSelector nodeSelector)
Invoked before this cluster node tries to join the cluster.
|
| 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 SqlClient |
DB2Pool.client(Vertx vertx,
DB2ConnectOptions database,
PoolOptions options)
Like
DB2Pool.client(DB2ConnectOptions, PoolOptions) with a specific
Vertx instance. |
static SqlClient |
DB2Pool.client(Vertx vertx,
List<DB2ConnectOptions> databases,
PoolOptions options)
Like
DB2Pool.client(List, PoolOptions) with a specific
Vertx instance. |
static SqlClient |
DB2Pool.client(Vertx vertx,
String connectionUri)
Like
DB2Pool.client(Vertx, String, PoolOptions) with default options. |
static SqlClient |
DB2Pool.client(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static Future<DB2Connection> |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions)
Like
DB2Connection.connect(Vertx, DB2ConnectOptions, Handler) but returns a
Future of the asynchronous result |
static void |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions,
Handler<AsyncResult<DB2Connection>> handler)
Create a connection to DB2 server with the given
connectOptions. |
static Future<DB2Connection> |
DB2Connection.connect(Vertx vertx,
String connectionUri)
Like
DB2Connection.connect(Vertx, String, Handler) but returns a Future of
the asynchronous result |
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 database,
PoolOptions options)
Like
DB2Pool.pool(DB2ConnectOptions, PoolOptions) with a specific
Vertx instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
List<DB2ConnectOptions> databases,
PoolOptions options)
Like
DB2Pool.pool(List, PoolOptions) with a specific
Vertx instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri)
Like
DB2Pool.pool(Vertx, String,PoolOptions) with default options. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
|
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
DB2Driver.createConnectionFactory(Vertx vertx,
SqlConnectOptions database) |
DB2Pool |
DB2Driver.newPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options,
io.vertx.core.impl.CloseFuture closeFuture) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static HtpasswdAuth |
HtpasswdAuth.create(Vertx vertx) |
static HtpasswdAuth |
HtpasswdAuth.create(Vertx vertx,
HtpasswdAuthOptions htpasswdAuthOptions) |
| Modifier and Type | Method and Description |
|---|---|
static JDBCAuth |
JDBCAuth.create(Vertx vertx,
JDBCClient client)
Deprecated.
Create a JDBC auth provider implementation
|
static JDBCHashStrategy |
JDBCHashStrategy.createPBKDF2(Vertx vertx)
Deprecated.
Implements a Hashing Strategy as per https://www.owasp.org/index.php/Password_Storage_Cheat_Sheet (2018-01-17).
|
JDBCAuth |
JDBCAuthOptions.createProvider(Vertx vertx)
Deprecated.
|
static JDBCHashStrategy |
JDBCHashStrategy.createSHA512(Vertx vertx)
Deprecated.
This is the current backwards compatible hashing implementation, new applications should prefer the
PBKDF2 implementation, unless the tradeoff between security and CPU usage is an option.
|
| Modifier and Type | Method and Description |
|---|---|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JWTAuthOptions config)
Create a JWT auth provider
|
| Modifier and Type | Method and Description |
|---|---|
static LdapAuthentication |
LdapAuthentication.create(Vertx vertx,
LdapAuthenticationOptions options)
Create a LDAP authentication provider
|
| Modifier and Type | Method and Description |
|---|---|
MongoAuth |
MongoAuthOptions.createProvider(Vertx vertx)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx)
Create a OAuth2 auth provider.
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2Options config)
Create a OAuth2 auth provider
|
| 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 |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
GitLabAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for GitLab.com.
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Github
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Twitter
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Stripe
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for SoundCloud
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Foursquare
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Mailchimp
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Heroku
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Github
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Twitter
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Stripe
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for SoundCloud
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Foursquare
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Mailchimp
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Heroku
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
CloudFoundryAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String uuaURL)
Create a OAuth2Auth provider for CloudFoundry UAA
|
static OAuth2Auth |
ShopifyAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String shop)
Create a OAuth2Auth provider for Shopify
|
static OAuth2Auth |
GitLabAuth.create(Vertx vertx,
String site,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for GitLab.
|
static OAuth2Auth |
AzureADAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String guid)
Create a OAuth2Auth provider for Microsoft Azure Active Directory
|
static OAuth2Auth |
CloudFoundryAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String uuaURL,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for CloudFoundry UAA
|
static OAuth2Auth |
ShopifyAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String shop,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Shopify
|
static OAuth2Auth |
GitLabAuth.create(Vertx vertx,
String site,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for GitLab.
|
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 |
IBMCloudAuth.create(Vertx vertx,
String region,
String clientId,
String clientSecret,
String guid)
Create a OAuth2Auth provider for IBM Cloud
|
static OAuth2Auth |
AmazonCognitoAuth.create(Vertx vertx,
String region,
String clientId,
String clientSecret,
String guid)
Create a OAuth2Auth provider for Amazon Cognito
|
static OAuth2Auth |
IBMCloudAuth.create(Vertx vertx,
String region,
String clientId,
String clientSecret,
String guid,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for IBM Cloud
|
static OAuth2Auth |
AmazonCognitoAuth.create(Vertx vertx,
String region,
String clientId,
String clientSecret,
String userPoolId,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Amazon Cognito
|
static Future<OAuth2Auth> |
SalesforceAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
IBMCloudAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
GoogleAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
AzureADAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
KeycloakAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
AmazonCognitoAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
SalesforceAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
IBMCloudAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
GoogleAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AzureADAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
KeycloakAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AmazonCognitoAuth.discover(Vertx vertx,
OAuth2Options config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
| Modifier and Type | Method and Description |
|---|---|
static PropertyFileAuthentication |
PropertyFileAuthentication.create(Vertx vertx,
String path)
Create a File authentication provider
|
static PropertyFileAuthorization |
PropertyFileAuthorization.create(Vertx vertx,
String path)
Create a File authentication provider
|
| Modifier and Type | Method and Description |
|---|---|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
org.apache.shiro.realm.Realm realm)
Deprecated.
Create a Shiro auth provider
|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthOptions options)
Deprecated.
Create a Shiro auth provider
|
AuthProvider |
ShiroAuthOptions.createProvider(Vertx vertx)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static WebAuthn |
WebAuthn.create(Vertx vertx)
Create a WebAuthN auth provider
|
static WebAuthn |
WebAuthn.create(Vertx vertx,
WebAuthnOptions options)
Create a WebAuthN auth provider
|
| Modifier and Type | Method and Description |
|---|---|
static ClusterHealthCheck |
ClusterHealthCheck.createProcedure(Vertx vertx)
|
static ClusterHealthCheck |
ClusterHealthCheck.createProcedure(Vertx vertx,
boolean detailed)
Creates a ready-to-use Vert.x cluster
HealthChecks procedure. |
void |
InfinispanClusterManager.init(Vertx vertx,
NodeSelector nodeSelector) |
| Modifier and Type | Method and Description |
|---|---|
static ConsulClient |
ConsulClient.create(Vertx vertx)
Create a Consul client with default options.
|
static ConsulClient |
ConsulClient.create(Vertx vertx,
ConsulClientOptions options)
Create a Consul client.
|
static Watch<EventList> |
Watch.events(String event,
Vertx vertx)
Creates
Watch to monitoring the custom user events. |
static Watch<EventList> |
Watch.events(String event,
Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring the custom user events. |
static Watch<KeyValue> |
Watch.key(String key,
Vertx vertx)
Creates
Watch to monitoring a specific key in the KV store. |
static Watch<KeyValue> |
Watch.key(String key,
Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring a specific key in the KV store. |
static Watch<KeyValueList> |
Watch.keyPrefix(String keyPrefix,
Vertx vertx)
Creates
Watch to monitoring a prefix of keys in the KV store. |
static Watch<KeyValueList> |
Watch.keyPrefix(String keyPrefix,
Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring a prefix of keys in the KV store. |
static Watch<NodeList> |
Watch.nodes(Vertx vertx)
Creates
Watch to monitoring the list of available nodes. |
static Watch<NodeList> |
Watch.nodes(Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring the list of available nodes. |
static Watch<ServiceEntryList> |
Watch.service(String service,
Vertx vertx)
Creates
Watch to monitoring the nodes providing the service. |
static Watch<ServiceEntryList> |
Watch.service(String service,
Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring the nodes providing the service. |
static Watch<ServiceList> |
Watch.services(Vertx vertx)
Creates
Watch to monitoring the list of available services. |
static Watch<ServiceList> |
Watch.services(Vertx vertx,
ConsulClientOptions options)
Creates
Watch to monitoring the list of available services. |
| Modifier and Type | Method and Description |
|---|---|
static MetricsService |
MetricsService.create(Vertx vertx)
Creates a metric service for a given
Vertx instance. |
| Constructor and Description |
|---|
ScheduledMetricsConsumer(Vertx vertx) |
ScheduledMetricsConsumer(Vertx vertx,
Measured measured) |
| Modifier and Type | Method and Description |
|---|---|
static TcpEventBusBridge |
TcpEventBusBridge.create(Vertx vertx) |
static TcpEventBusBridge |
TcpEventBusBridge.create(Vertx vertx,
BridgeOptions options) |
static TcpEventBusBridge |
TcpEventBusBridge.create(Vertx vertx,
BridgeOptions options,
NetServerOptions netServerOptions) |
static TcpEventBusBridge |
TcpEventBusBridge.create(Vertx vertx,
BridgeOptions options,
NetServerOptions netServerOptions,
Handler<BridgeEvent> eventHandler) |
| 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,
AuthenticationProvider provider)
Creates an instance of the default implementation of the
HealthCheckHandler. |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpServiceFactory.init(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,
DataSourceProvider dataSourceProvider)
Create a client using a data source provider
|
static JDBCClient |
JDBCClient.create(Vertx vertx,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
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
|
| 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.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
|
| 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.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
|
static MongoClient |
MongoClient.createWithMongoSettings(Vertx vertx,
JsonObject config,
String dataSourceName,
com.mongodb.MongoClientSettings settings)
Constructor targeting the jvm, like standard constructor
MongoClient.createShared(Vertx, JsonObject, String), but it accepts default mongoClientSettings
to configure mongo |
| Modifier and Type | Method and Description |
|---|---|
static <T> ReactiveWriteStream<T> |
ReactiveWriteStream.writeStream(Vertx vertx)
Create a reactive write stream
|
| Modifier and Type | Method and Description |
|---|---|
static ShellServer |
ShellServer.create(Vertx vertx)
Create a new shell server with specific options.
|
static ShellService |
ShellService.create(Vertx vertx)
Like
ShellService.create(Vertx, ShellServiceOptions), with default options. |
static ShellServer |
ShellServer.create(Vertx vertx,
ShellServerOptions options)
Create a new shell server with default options.
|
static ShellService |
ShellService.create(Vertx vertx,
ShellServiceOptions options)
Create a new shell service.
|
| Modifier and Type | Method and Description |
|---|---|
Vertx |
Completion.vertx() |
| Modifier and Type | Method and Description |
|---|---|
Vertx |
CommandProcess.vertx() |
| Modifier and Type | Method and Description |
|---|---|
static CommandResolver |
CommandResolver.baseCommands(Vertx vertx) |
Command |
CommandBuilder.build(Vertx vertx)
Build the command
|
static CommandRegistry |
CommandRegistry.create(Vertx vertx)
Create a new registry.
|
static Command |
Command.create(Vertx vertx,
Class<? extends AnnotatedCommand> clazz)
Create a command from a Java class, annotated with Vert.x Core CLI annotations.
|
static CommandRegistry |
CommandRegistry.getShared(Vertx vertx)
Get the shared registry for the Vert.x instance.
|
| Constructor and Description |
|---|
BaseCommandPack(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
void |
CommandResolverFactory.resolver(Vertx vertx,
Handler<AsyncResult<CommandResolver>> resolveHandler)
Obtain a command resolver for a Vert.x instance.
|
| Modifier and Type | Method and Description |
|---|---|
static SockJSTermHandler |
SockJSTermHandler.create(Vertx vertx,
String charset) |
static TermServer |
TermServer.createHttpTermServer(Vertx vertx)
Create a term server for the HTTP protocol.
|
static TermServer |
TermServer.createHttpTermServer(Vertx vertx,
HttpTermOptions options)
Create a term server for the HTTP protocol.
|
static TermServer |
TermServer.createHttpTermServer(Vertx vertx,
Router router)
Create a term server for the HTTP protocol, using an existing router.
|
static TermServer |
TermServer.createHttpTermServer(Vertx vertx,
Router router,
HttpTermOptions options)
Create a term server for the HTTP protocol, using an existing router.
|
static TermServer |
TermServer.createSSHTermServer(Vertx vertx)
Create a term server for the SSH protocol.
|
static TermServer |
TermServer.createSSHTermServer(Vertx vertx,
SSHTermOptions options)
Create a term server for the SSH protocol.
|
static TermServer |
TermServer.createTelnetTermServer(Vertx vertx)
Create a term server for the Telnet protocol.
|
static TermServer |
TermServer.createTelnetTermServer(Vertx vertx,
TelnetTermOptions options)
Create a term server for the Telnet protocol.
|
| Modifier and Type | Method and Description |
|---|---|
Vertx |
StompServer.vertx() |
Vertx |
StompClient.vertx() |
| Modifier and Type | Method and Description |
|---|---|
static Destination |
Destination.bridge(Vertx vertx,
BridgeOptions options) |
static StompServer |
StompServer.create(Vertx vertx)
Creates a
StompServer based on the default Stomp Server implementation, and use the default options. |
static StompServerHandler |
StompServerHandler.create(Vertx vertx)
Creates an instance of
StompServerHandler using the default (compliant) implementation. |
static StompClient |
StompClient.create(Vertx vertx)
Creates a
StompClient using the default implementation. |
static StompServer |
StompServer.create(Vertx vertx,
NetServer netServer)
Creates a
StompServer based on the default Stomp Server implementation. |
static StompServer |
StompServer.create(Vertx vertx,
NetServer net,
StompServerOptions options)
Creates a
StompServer based on the default Stomp Server implementation. |
static StompClient |
StompClient.create(Vertx vertx,
StompClientOptions options)
Creates a
StompClient using the default implementation. |
static StompServer |
StompServer.create(Vertx vertx,
StompServerOptions options)
Creates a
StompServer based on the default Stomp Server implementation. |
Destination |
DestinationFactory.create(Vertx vertx,
String name)
Creates a destination for the given address.
|
static Destination |
Destination.queue(Vertx vertx,
String destination) |
static Destination |
Destination.topic(Vertx vertx,
String destination) |
| 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.
|
| 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(Future<Vertx> createVertx)
Create a new rule with an asynchronous supplier for creating a Vert.x instance.
|
RunTestOnContext(Future<Vertx> createVertx,
java.util.function.BiConsumer<Vertx,java.util.function.Consumer<Void>> closeVertx)
Create a new rule with an asynchronous supplier and consumer for creating and closing a Vert.x instance.
|
RunTestOnContext(Future<Vertx> createVertx,
java.util.function.BiConsumer<Vertx,java.util.function.Consumer<Void>> closeVertx)
Create a new rule with an asynchronous supplier and consumer for creating and closing a Vert.x instance.
|
RunTestOnContext(java.util.function.Supplier<Vertx> createVertx)
Create a new rule with supplier for creating a Vert.x instance.
|
RunTestOnContext(java.util.function.Supplier<Vertx> createVertx,
java.util.function.BiConsumer<Vertx,java.util.function.Consumer<Void>> closeVertx)
Create a new rule with supplier/consumer for creating/closing a Vert.x instance.
|
RunTestOnContext(java.util.function.Supplier<Vertx> createVertx,
java.util.function.BiConsumer<Vertx,java.util.function.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 |
|---|---|
Vertx |
RoutingContext.vertx() |
| Modifier and Type | Method and Description |
|---|---|
static Router |
Router.router(Vertx vertx)
Create a router
|
| Modifier and Type | Method and Description |
|---|---|
static Future<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
Create a new OpenAPI3RouterFactory
|
static Future<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
Create a new OpenAPI3RouterFactory
|
| 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 CacheStore |
CacheStore.sharedDataStore(Vertx vertx)
Builds a cache store that uses an
AsyncMap from
SharedData. |
| Constructor and Description |
|---|
CachingTemplateEngine(Vertx vertx,
String ext) |
| Modifier and Type | Method and Description |
|---|---|
static FaviconHandler |
FaviconHandler.create(Vertx vertx)
Create a handler with defaults
|
static ErrorHandler |
ErrorHandler.create(Vertx vertx)
Create an error handler using defaults
|
static ErrorHandler |
ErrorHandler.create(Vertx vertx,
boolean displayExceptionDetails)
Create an error handler
|
static DigestAuthHandler |
DigestAuthHandler.create(Vertx vertx,
HtdigestAuth authProvider)
Create a digest auth handler
|
static DigestAuthHandler |
DigestAuthHandler.create(Vertx vertx,
HtdigestAuth authProvider,
long nonceExpireTimeout)
Create a digest auth handler, specifying the expire timeout for nonces.
|
static FaviconHandler |
FaviconHandler.create(Vertx vertx,
long maxAgeSeconds)
Create a handler with the specified max cache time
|
static OAuth2AuthHandler |
OAuth2AuthHandler.create(Vertx vertx,
OAuth2Auth authProvider)
Create a OAuth2 auth handler without host pinning.
|
static OAuth2AuthHandler |
OAuth2AuthHandler.create(Vertx vertx,
OAuth2Auth authProvider,
String callbackURL)
Create a OAuth2 auth handler with host pinning
|
static CSRFHandler |
CSRFHandler.create(Vertx vertx,
String secret)
Instantiate a new CSRFHandlerImpl with a secret
|
static FaviconHandler |
FaviconHandler.create(Vertx vertx,
String path)
Create a handler attempting to load favicon file from the specified path
|
static ErrorHandler |
ErrorHandler.create(Vertx vertx,
String errorTemplateName)
Create an error handler
|
static ErrorHandler |
ErrorHandler.create(Vertx vertx,
String errorTemplateName,
boolean displayExceptionDetails)
Create an error handler
|
static FaviconHandler |
FaviconHandler.create(Vertx vertx,
String path,
long maxAgeSeconds)
Create a handler attempting to load favicon file from the specified path, and with the specified max cache time
|
| 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 | Method and Description |
|---|---|
static Future<RouterBuilder> |
RouterBuilder.create(Vertx vertx,
String url)
Create a new
RouterBuilder |
static void |
RouterBuilder.create(Vertx vertx,
String url,
Handler<AsyncResult<RouterBuilder>> handler)
Like
this#create(Vertx, String) |
static Future<RouterBuilder> |
RouterBuilder.create(Vertx vertx,
String url,
OpenAPILoaderOptions options)
Create a new
RouterBuilder |
static void |
RouterBuilder.create(Vertx vertx,
String url,
OpenAPILoaderOptions options,
Handler<AsyncResult<RouterBuilder>> handler)
Like
this#create(Vertx, String, OpenAPILoaderOptions) |
| Modifier and Type | Method and Description |
|---|---|
static SessionStore |
SessionStore.create(Vertx vertx)
Create a Session store given a backend and configuration JSON.
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx)
Create a session store
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx)
Create a session store
|
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 LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName,
long reaperInterval)
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.
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
| Modifier and Type | Method and Description |
|---|---|
static CookieSessionStore |
CookieSessionStore.create(Vertx vertx,
String secret)
Creates a CookieSessionStore.
|
| Modifier and Type | Method and Description |
|---|---|
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options)
Create a new
InfinispanSessionStore for the given configuration. |
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options,
org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager)
Like
InfinispanSessionStore.create(Vertx, JsonObject) but with a pre-configured Infinispan Client. |
| Modifier and Type | Method and Description |
|---|---|
static RedisSessionStore |
RedisSessionStore.create(Vertx vertx,
long retryTimeoutMs,
Redis redis)
Creates a RedisSessionStore with the given retry TO.
|
static RedisSessionStore |
RedisSessionStore.create(Vertx vertx,
Redis redis)
Creates a RedisSessionStore with the default retry TO.
|
| Modifier and Type | Method and Description |
|---|---|
static FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
static FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx,
String extension)
Create a template engine using defaults
|
| Modifier and Type | Method and Description |
|---|---|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx,
String extension)
Create a template engine using defaults
|
| Modifier and Type | Method and Description |
|---|---|
static JadeTemplateEngine |
JadeTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
static JadeTemplateEngine |
JadeTemplateEngine.create(Vertx vertx,
String extension)
Create a template engine using defaults
|
| Modifier and Type | Method and Description |
|---|---|
static MVELTemplateEngine |
MVELTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
static MVELTemplateEngine |
MVELTemplateEngine.create(Vertx vertx,
String extension)
Create a template engine using defaults
|
| Modifier and Type | Method and Description |
|---|---|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx,
com.mitchellbosecke.pebble.PebbleEngine engine)
Create a template engine using a custom Builder, e.g.
|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx,
String extension)
Create a template engine using defaults
|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx,
String extension,
com.mitchellbosecke.pebble.PebbleEngine engine)
Create a template engine using a custom Builder, e.g.
|
| Modifier and Type | Method and Description |
|---|---|
static ThymeleafTemplateEngine |
ThymeleafTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
| 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 JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource)
Create a JDBC pool using a pre-initialized data source.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource,
JsonObject config)
Create a JDBC pool using a pre-initialized data source.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSourceProvider dataSourceProvider)
Create a JDBC pool which maintains its own data source.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JDBCConnectOptions connectOptions,
PoolOptions poolOptions)
Create a JDBC pool which maintains its own data source.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JsonObject config)
Create a JDBC pool which maintains its own data source.
|
| Modifier and Type | Method and Description |
|---|---|
static SchemaRouter |
SchemaRouter.create(Vertx vertx,
HttpClient client,
FileSystem fs,
SchemaRouterOptions schemaRouterOptions)
Create a new
SchemaRouter |
static SchemaRouter |
SchemaRouter.create(Vertx vertx,
SchemaRouterOptions schemaRouterOptions)
Create a new
SchemaRouter |
| Constructor and Description |
|---|
SchemaRouterImpl(Vertx vertx,
HttpClient client,
FileSystem fs,
SchemaRouterOptions options) |
| Modifier and Type | Method and Description |
|---|---|
static Schema |
Draft201909SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Parse a draft2019-09 schema
|
| Modifier and Type | Method and Description |
|---|---|
static Schema |
Draft7SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Parse a draft-7 schema
|
| Modifier and Type | Method and Description |
|---|---|
static Schema |
OpenAPI3SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Parse an OpenAPI 3 schema
|
| Modifier and Type | Method and Description |
|---|---|
Vertx |
VertxParameterProvider.newInstance(org.junit.jupiter.api.extension.ExtensionContext extensionContext,
org.junit.jupiter.api.extension.ParameterContext parameterContext) |
Vertx |
RunTestOnContext.vertx() |
| Modifier and Type | Method and Description |
|---|---|
ParameterClosingConsumer<Vertx> |
VertxParameterProvider.parameterClosingConsumer() |
Class<Vertx> |
VertxParameterProvider.type() |
| Constructor and Description |
|---|
RunTestOnContext(java.util.function.Supplier<Future<Vertx>> supplier)
Create an instance of this extension that gets a
Vertx object using the specified asynchronous supplier. |
RunTestOnContext(java.util.function.Supplier<Future<Vertx>> supplier,
java.util.function.Function<Vertx,Future<Void>> shutdown)
Create an instance of this extension that gets a
Vertx object using the specified asynchronous supplier. |
RunTestOnContext(java.util.function.Supplier<Future<Vertx>> supplier,
java.util.function.Function<Vertx,Future<Void>> shutdown)
Create an instance of this extension that gets a
Vertx object using the specified asynchronous supplier. |
| 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
|
| 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,
KafkaClientOptions options)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
KafkaClientOptions options,
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,
KafkaClientOptions options,
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,
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,
KafkaClientOptions options)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
KafkaClientOptions options,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaWriteStream instance
|
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> 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,
org.apache.kafka.clients.producer.Producer<K,V> producer)
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)
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,
Class<K> keyType,
Class<V> valueType)
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> 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.createShared(Vertx vertx,
String name,
KafkaClientOptions options)
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,
KafkaClientOptions options,
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,
KafkaClientOptions options,
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,
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 |
|---|---|
void |
GroovyVerticleFactory.init(Vertx vertx) |
| Modifier and Type | Method and Description |
|---|---|
void |
MavenVerticleFactory.init(Vertx vertx) |
| 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
|
| Modifier and Type | Method and Description |
|---|---|
static Future<MSSQLConnection> |
MSSQLConnection.connect(Vertx vertx,
MSSQLConnectOptions connectOptions)
Like
MSSQLConnection.connect(Vertx, MSSQLConnectOptions, Handler) but returns a Future of the asynchronous result |
static void |
MSSQLConnection.connect(Vertx vertx,
MSSQLConnectOptions connectOptions,
Handler<AsyncResult<MSSQLConnection>> handler)
Create a connection to SQL Server with the given
connectOptions. |
static Future<MSSQLConnection> |
MSSQLConnection.connect(Vertx vertx,
String connectionUri)
Like
MSSQLConnection.connect(Vertx, String, Handler) but returns a Future of the asynchronous result |
static void |
MSSQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MSSQLConnection>> handler)
Like
MSSQLConnection.connect(Vertx, MSSQLConnectOptions, Handler) with options built from connectionUri. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
List<MSSQLConnectOptions> databases,
PoolOptions options)
Like
MSSQLPool.pool(List, PoolOptions) with a specific Vertx instance. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
MSSQLConnectOptions database,
PoolOptions options)
Like
MSSQLPool.pool(MSSQLConnectOptions, PoolOptions) with a specific Vertx instance. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
String connectionUri)
Like
MSSQLPool.pool(Vertx, String, PoolOptions) with default options. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
Like
MSSQLPool.pool(Vertx, MSSQLConnectOptions, PoolOptions) with database built from connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
MSSQLDriver.createConnectionFactory(Vertx vertx,
SqlConnectOptions database) |
MSSQLPool |
MSSQLDriver.newPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options,
io.vertx.core.impl.CloseFuture closeFuture) |
| Modifier and Type | Method and Description |
|---|---|
static Future<MySQLConnection> |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions)
Like
MySQLConnection.connect(Vertx, MySQLConnectOptions, Handler) but returns a Future of the asynchronous result |
static void |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions,
Handler<AsyncResult<MySQLConnection>> handler)
Create a connection to MySQL server with the given
connectOptions. |
static Future<MySQLConnection> |
MySQLConnection.connect(Vertx vertx,
String connectionUri)
Like
MySQLConnection.connect(Vertx, String, Handler) but returns a Future of the asynchronous result |
static void |
MySQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MySQLConnection>> handler)
Like
MySQLConnection.connect(Vertx, MySQLConnectOptions, Handler) with options built from connectionUri. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
List<MySQLConnectOptions> databases,
PoolOptions options)
Like
MySQLPool.pool(List, PoolOptions) with a specific Vertx instance. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
MySQLConnectOptions database,
PoolOptions options)
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 default options. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
Like
MySQLPool.pool(Vertx, MySQLConnectOptions, PoolOptions) with database built from connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
MySQLDriver.createConnectionFactory(Vertx vertx,
SqlConnectOptions database) |
MySQLPool |
MySQLDriver.newPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options,
io.vertx.core.impl.CloseFuture closeFuture) |
| Modifier and Type | Method and Description |
|---|---|
static SqlClient |
PgPool.client(Vertx vertx,
List<PgConnectOptions> databases,
PoolOptions options)
Like
PgPool.client(List, PoolOptions) with a specific Vertx instance. |
static SqlClient |
PgPool.client(Vertx vertx,
PgConnectOptions database,
PoolOptions options)
Like
PgPool.client(PgConnectOptions, PoolOptions) with a specific Vertx instance. |
static SqlClient |
PgPool.client(Vertx vertx,
PoolOptions poolOptions)
Like
PgPool.client(Vertx, PgConnectOptions, PoolOptions) with database retrieved from the environment variables. |
static SqlClient |
PgPool.client(Vertx vertx,
String connectionUri)
Like
PgPool.client(Vertx, String,PoolOptions) with default options. |
static SqlClient |
PgPool.client(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static Future<PgConnection> |
PgConnection.connect(Vertx vertx)
Like
PgConnection.connect(Vertx, Handler) but returns a Future of the asynchronous result |
static void |
PgConnection.connect(Vertx vertx,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from the environment variables. |
static Future<PgConnection> |
PgConnection.connect(Vertx vertx,
PgConnectOptions options)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) but returns a Future of the asynchronous result |
static void |
PgConnection.connect(Vertx vertx,
PgConnectOptions options,
Handler<AsyncResult<PgConnection>> handler)
Connects to the database and returns the connection if that succeeds.
|
static Future<PgConnection> |
PgConnection.connect(Vertx vertx,
String connectionUri)
Like
PgConnection.connect(Vertx, String, Handler) but returns a Future of the asynchronous result |
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,
List<PgConnectOptions> databases,
PoolOptions poolOptions)
Like
PgPool.pool(List, PoolOptions) with a specific Vertx instance. |
static PgPool |
PgPool.pool(Vertx vertx,
PgConnectOptions database,
PoolOptions options)
Like
PgPool.pool(PgConnectOptions, PoolOptions) with a specific Vertx instance. |
static PgPool |
PgPool.pool(Vertx vertx,
PoolOptions options)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with the database retrieved from the environment variables. |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri)
Like
PgPool.pool(Vertx, String,PoolOptions) with default options. |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with database retrieved from the given connectionUri. |
| Modifier and Type | Method and Description |
|---|---|
static PgSubscriber |
PgSubscriber.subscriber(Vertx vertx,
PgConnectOptions options)
Create a subscriber.
|
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
PgDriver.createConnectionFactory(Vertx vertx,
SqlConnectOptions database) |
PgPool |
PgDriver.newPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options,
io.vertx.core.impl.CloseFuture closeFuture) |
| Modifier and Type | Method and Description |
|---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx)
Create and return a client configured with the default options.
|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
JsonObject config)
Like
RabbitMQClient.create(Vertx, RabbitMQOptions) but with a JsonObject config object. |
static RabbitMQPublisher |
RabbitMQPublisher.create(Vertx vertx,
RabbitMQClient client,
RabbitMQPublisherOptions options)
Create and return a publisher using the specified client.
|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
| 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 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.
|
| 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 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 ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery. |
| Modifier and Type | Method and Description |
|---|---|
void |
RedisBackendService.init(Vertx vertx,
JsonObject configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConsulServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
| Modifier and Type | Method and Description |
|---|---|
void |
DockerLinksServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
| 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 |
|---|---|
void |
ZookeeperServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future) |
| Modifier and Type | Method and Description |
|---|---|
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address)
Deprecated.
|
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address,
DeliveryOptions options)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a local service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
| Constructor and Description |
|---|
ServiceBinder(Vertx vertx)
Creates a factory.
|
ServiceProxyBuilder(Vertx vertx)
Creates a builder.
|
| Modifier and Type | Method and Description |
|---|---|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx)
Creates a ready-to-use Vert.x cluster
HealthChecks procedure. |
void |
HazelcastClusterManager.init(Vertx vertx,
NodeSelector nodeSelector) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteClusterManager.init(Vertx vertx,
NodeSelector nodeSelector) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.ignite.configuration.IgniteConfiguration |
ConfigHelper.toIgniteConfig(Vertx vertx,
IgniteOptions options) |
static javax.cache.configuration.Factory<SSLContext> |
ConfigHelper.toSslContextFactoryConfig(Vertx vertx,
IgniteSslOptions options) |
| Modifier and Type | Method and Description |
|---|---|
void |
ZookeeperClusterManager.init(Vertx vertx,
NodeSelector nodeSelector) |
| Modifier and Type | Method and Description |
|---|---|
static Pool |
Pool.pool(Vertx vertx,
SqlConnectOptions database,
PoolOptions options)
Create a connection pool to the
database with the given options. |
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
Driver.createConnectionFactory(Vertx vertx,
SqlConnectOptions database)
Create a connection factory to the given
database. |
default Pool |
Driver.createPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options)
Create a connection pool to the database configured with the given
connectOptions and poolOptions. |
Pool |
Driver.newPool(Vertx vertx,
List<? extends SqlConnectOptions> databases,
PoolOptions options,
io.vertx.core.impl.CloseFuture closeFuture)
Create a connection pool to the database configured with the given
connectOptions and poolOptions. |
Copyright © 2022 Eclipse. All rights reserved.