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 |
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 |
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.