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 AmqpBridge |
AmqpBridge.create(Vertx vertx)
Creates a Bridge.
|
static AmqpBridge |
AmqpBridge.create(Vertx vertx,
AmqpBridgeOptions options)
Creates a Bridge with 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.createNonShared(Vertx vertx)
Deprecated.
use
CassandraClient.create(Vertx) instead |
static CassandraClient |
CassandraClient.createNonShared(Vertx vertx,
CassandraClientOptions options)
Deprecated.
|
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 |
---|---|
void |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
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 . |
void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Transforms the given
input into a JsonObject . |
Constructor and Description |
---|
FileSet(Vertx vertx,
File root,
JsonObject set)
Creates a new
FileSet from a json object. |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
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 |
---|---|
void |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
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
|
protected Vertx |
Starter.vertx
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.exceptionHandler(Handler<Throwable> handler)
Set a default exception handler for
Context , set on Context.exceptionHandler(Handler) at creation. |
Vertx |
Verticle.getVertx()
Get a reference to the Vert.x instance that deployed this verticle
|
Vertx |
AbstractVerticle.getVertx()
Get the Vert.x instance
|
Vertx |
Context.owner() |
static Vertx |
Vertx.vertx()
Creates a non clustered instance using default options.
|
static Vertx |
Vertx.vertx(VertxOptions options)
Creates a non clustered instance using the specified options
|
Modifier and Type | Method and Description |
---|---|
void |
Launcher.afterStartingVertx(Vertx vertx)
Hook for sub-classes of
Launcher after the vertx instance is started. |
void |
Launcher.beforeStoppingVertx(Vertx vertx) |
void |
Launcher.handleDeployFailed(Vertx vertx,
String mainVerticle,
DeploymentOptions deploymentOptions,
Throwable cause)
A deployment failure has been encountered.
|
void |
Verticle.init(Vertx vertx,
Context context)
Initialise the verticle with the Vert.x instance and the context.
|
void |
AbstractVerticle.init(Vertx vertx,
Context context)
Initialise the verticle.
|
Modifier and Type | Method and Description |
---|---|
static void |
Vertx.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a clustered instance using the specified options.
|
Modifier and Type | Method and Description |
---|---|
default KeyManagerFactory |
KeyCertOptions.getKeyManagerFactory(Vertx vertx)
Create and return the key manager factory for these options.
|
default TrustManagerFactory |
TrustOptions.getTrustManagerFactory(Vertx vertx)
Create and return the trust manager factory for these options.
|
default java.util.function.Function<String,X509KeyManager> |
KeyCertOptions.keyManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to
X509KeyManager instance. |
default java.util.function.Function<String,TrustManager[]> |
TrustOptions.trustManagerMapper(Vertx vertx)
Returns a function that maps SNI server names to a
TrustManagerFactory instance. |
Modifier and Type | Method and Description |
---|---|
Vertx |
VertxFactory.vertx() |
Vertx |
VertxFactory.vertx(VertxOptions options) |
Vertx |
VertxFactory.vertx(VertxOptions options,
io.vertx.core.net.impl.transport.Transport transport) |
Modifier and Type | Method and Description |
---|---|
default void |
VerticleFactory.init(Vertx vertx)
Initialise the factory
|
Modifier and Type | Method and Description |
---|---|
void |
VertxFactory.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
void |
VertxFactory.clusteredVertx(VertxOptions options,
io.vertx.core.net.impl.transport.Transport transport,
Handler<AsyncResult<Vertx>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManager.setVertx(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
default void |
VertxMetrics.vertxCreated(Vertx vertx)
Callback to signal when the Vertx instance is fully initialized.
|
Modifier and Type | Method and Description |
---|---|
static ResolverProvider |
ResolverProvider.factory(Vertx vertx,
AddressResolverOptions options) |
Modifier and Type | Method and Description |
---|---|
static void |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions,
Handler<AsyncResult<DB2Connection>> handler)
Create a connection to DB2 server with the given
connectOptions . |
static void |
DB2Connection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<DB2Connection>> handler)
Like
DB2Connection.connect(Vertx, DB2ConnectOptions, Handler) with options build
from connectionUri . |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
DB2ConnectOptions connectOptions,
PoolOptions poolOptions)
Like
DB2Pool.pool(DB2ConnectOptions, PoolOptions) with a specific
Vertx instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri)
Like
DB2Pool.pool(Vertx, String,PoolOptions) with a default
poolOptions .. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
DB2Pool.pool(Vertx, DB2ConnectOptions, PoolOptions) with
connectOptions build from connectionUri . |
Modifier and Type | Method and Description |
---|---|
Pool |
DB2Driver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
Modifier and Type | Method and Description |
---|---|
static AsyncSQLClient |
PostgreSQLClient.createNonShared(Vertx vertx,
JsonObject config)
Create a PostgreSQL client which maintains its own pool.
|
static AsyncSQLClient |
MySQLClient.createNonShared(Vertx vertx,
JsonObject config)
Create a MySQL client which maintains its own pool.
|
static AsyncSQLClient |
PostgreSQLClient.createShared(Vertx vertx,
JsonObject config)
Like
PostgreSQLClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default pool name |
static AsyncSQLClient |
MySQLClient.createShared(Vertx vertx,
JsonObject config)
Like
MySQLClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default pool name |
static AsyncSQLClient |
PostgreSQLClient.createShared(Vertx vertx,
JsonObject config,
String poolName)
Create a PostgreSQL client which shares its pool with any other MySQL clients created with the same pool name.
|
static AsyncSQLClient |
MySQLClient.createShared(Vertx vertx,
JsonObject config,
String poolName)
Create a MySQL client which shares its data source with any other MySQL clients created with the same
data source name
|
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) |
AuthProvider |
HtpasswdAuthOptions.createProvider(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
static JDBCAuth |
JDBCAuth.create(Vertx vertx,
JDBCClient client)
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,
JsonObject config)
Deprecated.
|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JWTAuthOptions config)
Create a JWT auth provider
|
Modifier and Type | Method and Description |
---|---|
MongoAuth |
MongoAuthOptions.createProvider(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow)
Deprecated.
the flow configuration should be passed in the config object
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow,
OAuth2ClientOptions config)
Deprecated.
the flow configuration should be passed in the config object
|
static OAuth2Auth |
OAuth2Auth.createKeycloak(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Deprecated.
You should use the provider helper
KeycloakAuth instead.
Create a OAuth2 auth provider |
Modifier and Type | Method and Description |
---|---|
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 |
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 |
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 |
AzureADAuth.create(Vertx vertx,
String clientId,
String clientSecret,
String guid,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Microsoft Azure Active Directory
|
static void |
SalesforceAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
GoogleAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AzureADAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
KeycloakAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
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
|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthRealmType realmType,
JsonObject config)
Deprecated.
|
AuthProvider |
ShiroAuthOptions.createProvider(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx)
|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx,
boolean detailed)
Creates a ready-to-use Vert.x cluster
HealthChecks procedure. |
void |
InfinispanClusterManager.setVertx(Vertx vertx) |
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 ConsulService |
ConsulService.createEventBusProxy(Vertx vertx,
String address)
Create a proxy to a service that is deployed somewhere on the event bus
|
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,
AuthProvider 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,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
static JDBCClient |
JDBCClient.createNonShared(Vertx vertx,
JsonObject config)
Deprecated.
use
JDBCClient.create(Vertx, JsonObject) instead |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config)
Like
JDBCClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a JDBC client which shares its data source with any other JDBC clients created with the same
data source name
|
Modifier and Type | Method and Description |
---|---|
static MailClient |
MailClient.create(Vertx vertx,
MailConfig config)
Create a non shared instance of the mail client.
|
static MailService |
MailService.createEventBusProxy(Vertx vertx,
String address)
create a proxy of MailService that delegates to the mail service running somewhere else via the event bus
|
static MailClient |
MailClient.createNonShared(Vertx vertx,
MailConfig config)
Deprecated.
use
MailClient.create(Vertx, MailConfig) instead |
static MailClient |
MailClient.createShared(Vertx vertx,
MailConfig config)
Like
MailClient.createShared(io.vertx.core.Vertx, MailConfig, String) but with the default pool name |
static MailClient |
MailClient.createShared(Vertx vertx,
MailConfig config,
String poolName)
Create a Mail client which shares its connection pool with any other Mail clients created with the same
pool name
|
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 MongoService |
MongoService.createEventBusProxy(Vertx vertx,
String address)
Create a proxy to a service that is deployed somewhere on the event bus
|
static MongoClient |
MongoClient.createNonShared(Vertx vertx,
JsonObject config)
Deprecated.
use
MongoClient.create(Vertx, JsonObject) instead |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
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(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 void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
Modifier and Type | Method and Description |
---|---|
static WebClient |
WebClient.create(Vertx vertx)
Create a web client using the provided
vertx instance and default options. |
static WebClient |
WebClient.create(Vertx vertx,
WebClientOptions options)
Create a web client using the provided
vertx instance. |
Modifier and Type | Method and Description |
---|---|
static SockJSHandler |
SockJSHandler.create(Vertx vertx)
Create a SockJS handler
|
static SockJSHandler |
SockJSHandler.create(Vertx vertx,
SockJSHandlerOptions options)
Create a SockJS handler
|
Modifier and Type | 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 FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static JadeTemplateEngine |
JadeTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static ThymeleafTemplateEngine |
ThymeleafTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
static MVELTemplateEngine |
MVELTemplateEngine.create(Vertx vertx)
Deprecated.
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static FreeMarkerTemplateEngine |
FreeMarkerTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static HandlebarsTemplateEngine |
HandlebarsTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static JadeTemplateEngine |
JadeTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static MVELTemplateEngine |
MVELTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
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 Vertx |
VertxExtension.retrieveVertx(Executable declaringExecutable,
org.junit.jupiter.api.extension.ExtensionContext context) |
Modifier and Type | Method and Description |
---|---|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
org.apache.kafka.clients.admin.AdminClient adminClient)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
Properties config)
Create a new KafkaAdminClient instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Create a new KafkaConsumer instance from a native
Consumer . |
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config)
Create a new KafkaReadStream instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Map<String,Object> config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Map<String,String> config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
Properties config,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaConsumer instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
Map<String,Object> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaProducer instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaProducer instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.create(Vertx vertx,
Map<String,String> config,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaProducer instance
|
static <K,V> 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,
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 |
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 void |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions,
Handler<AsyncResult<MySQLConnection>> handler)
Create a connection to MySQL server with the given
connectOptions . |
static void |
MySQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MySQLConnection>> handler)
Like
MySQLConnection.connect(Vertx, MySQLConnectOptions, Handler) with options build from connectionUri . |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
MySQLConnectOptions connectOptions,
PoolOptions poolOptions)
Like
MySQLPool.pool(MySQLConnectOptions, PoolOptions) with a specific Vertx instance. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri)
Like
MySQLPool.pool(Vertx, String,PoolOptions) with a default poolOptions .. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
MySQLPool.pool(Vertx, MySQLConnectOptions, PoolOptions) with connectOptions build from connectionUri . |
Modifier and Type | Method and Description |
---|---|
Pool |
MySQLDriver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
Modifier and Type | Method and Description |
---|---|
static void |
PgConnection.connect(Vertx vertx,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from the environment variables. |
static void |
PgConnection.connect(Vertx vertx,
PgConnectOptions options,
Handler<AsyncResult<PgConnection>> handler)
Connects to the database and returns the connection if that succeeds.
|
static void |
PgConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from connectionUri . |
static PgPool |
PgPool.pool(Vertx vertx,
PgConnectOptions connectOptions,
PoolOptions poolOptions)
Like
PgPool.pool(PgConnectOptions, PoolOptions) with a specific Vertx instance. |
static PgPool |
PgPool.pool(Vertx vertx,
PoolOptions poolOptions)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with connectOptions build from the environment variables. |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri)
Like
PgPool.pool(Vertx, String,PoolOptions) with a default poolOptions . |
static PgPool |
PgPool.pool(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
Like
PgPool.pool(Vertx, PgConnectOptions, PoolOptions) with connectOptions build from connectionUri . |
Modifier and Type | Method and Description |
---|---|
static PgSubscriber |
PgSubscriber.subscriber(Vertx vertx,
PgConnectOptions options)
Create a subscriber.
|
Modifier and Type | Method and Description |
---|---|
Pool |
PgDriver.createPool(Vertx vertx,
SqlConnectOptions options,
PoolOptions poolOptions) |
Modifier and Type | Method and Description |
---|---|
static 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 RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
RabbitMQOptions config)
Create and return a client.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Vertx |
Vertx.newInstance(Vertx arg) |
Constructor and Description |
---|
Vertx(Vertx delegate) |
Modifier and Type | Method and Description |
---|---|
static RedisClient |
RedisClient.create(Vertx vertx)
Deprecated.
|
static RedisClient |
RedisClient.create(Vertx vertx,
JsonObject config)
Deprecated.
|
static RedisClient |
RedisClient.create(Vertx vertx,
RedisOptions config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Redis |
Redis.createClient(Vertx vertx)
Create a new redis client using the default client options.
|
static Redis |
Redis.createClient(Vertx vertx,
RedisOptions options)
Create a new redis client using the given client options.
|
static Redis |
Redis.createClient(Vertx vertx,
String connectionString)
Create a new redis client using the default client options.
|
Modifier and Type | Method and Description |
---|---|
static RedisSentinel |
RedisSentinel.create(Vertx vertx)
Deprecated.
|
static RedisSentinel |
RedisSentinel.create(Vertx vertx,
JsonObject config)
Deprecated.
|
static RedisSentinel |
RedisSentinel.create(Vertx vertx,
RedisOptions options)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Vertx |
Vertx.newInstance(Vertx arg) |
Constructor and Description |
---|
Vertx(Vertx delegate) |
Modifier and Type | Method and Description |
---|---|
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
Handler<ServiceDiscovery> completionHandler)
Deprecated.
this will be removed in Vert.x 4, instead use
ServiceDiscovery.create(Vertx) |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery . |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options,
Handler<ServiceDiscovery> completionHandler)
Deprecated.
this will be removed in Vert.x 4, instead use
ServiceDiscovery.create(Vertx, ServiceDiscoveryOptions) |
Modifier and Type | Method and Description |
---|---|
void |
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 |
---|---|
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address)
Deprecated.
use instead
ServiceProxyBuilder |
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address,
DeliveryOptions options)
Deprecated.
use instead
ServiceProxyBuilder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
use instead
ServiceBinder |
Constructor and Description |
---|
ServiceBinder(Vertx vertx)
Creates a factory.
|
ServiceProxyBuilder(Vertx vertx)
Creates a builder.
|
Modifier and Type | Method and Description |
---|---|
static Handler<Promise<Status>> |
ClusterHealthCheck.createProcedure(Vertx vertx)
Creates a ready-to-use Vert.x cluster
HealthChecks procedure. |
void |
HazelcastClusterManager.setVertx(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
void |
IgniteClusterManager.setVertx(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
void |
ZookeeperClusterManager.setVertx(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
static Pool |
Pool.pool(Vertx vertx,
SqlConnectOptions connectOptions,
PoolOptions poolOptions)
Create a connection pool to the database configured with the given
connectOptions and poolOptions . |
Modifier and Type | Method and Description |
---|---|
Pool |
Driver.createPool(Vertx vertx,
SqlConnectOptions connectOptions,
PoolOptions poolOptions)
Create a connection pool to the database configured with the given
connectOptions and poolOptions . |
Copyright © 2020 Eclipse. All rights reserved.