Modifier and Type | Method and Description |
---|---|
Vertx |
VertxParameterProvider.newInstance(org.junit.jupiter.api.extension.ExtensionContext extensionContext,
org.junit.jupiter.api.extension.ParameterContext parameterContext) |
Modifier and Type | Method and Description |
---|---|
ParameterClosingConsumer<Vertx> |
VertxParameterProvider.parameterClosingConsumer() |
Class<Vertx> |
VertxParameterProvider.type() |
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 CassandraClient |
CassandraClient.create(Vertx vertx)
Like
CassandraClient.create(io.vertx.rxjava.core.Vertx) 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(io.vertx.rxjava.core.Vertx) with default options and client name. |
static CassandraClient |
CassandraClient.createShared(Vertx vertx,
CassandraClientOptions options)
Like
CassandraClient.createShared(io.vertx.rxjava.core.Vertx) with default client name. |
static CassandraClient |
CassandraClient.createShared(Vertx vertx,
String clientName)
Like
CassandraClient.createShared(io.vertx.rxjava.core.Vertx) 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 and listening to local messages only.
|
static HystrixMetricHandler |
HystrixMetricHandler.create(Vertx vertx,
String address)
Creates the handler, listening only to local messages.
|
static HystrixMetricHandler |
HystrixMetricHandler.create(Vertx vertx,
String address,
boolean localOnly)
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 | Field and Description |
---|---|
protected Vertx |
AbstractVerticle.vertx |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Vertx> |
Vertx.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.exceptionHandler(Handler<Throwable> handler)
Set a default exception handler for
Context , set on Context.exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>) at creation. |
static Vertx |
Vertx.newInstance(Vertx arg) |
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 Single<Vertx> |
Vertx.rxClusteredVertx(VertxOptions options)
Creates a clustered instance using the specified 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 Observable<String> |
RxHelper.deployVerticle(Vertx vertx,
Verticle verticle)
Deploy a verticle you have created yourself, using an
RxJava vertx instance.
|
static Observable<String> |
RxHelper.deployVerticle(Vertx vertx,
Verticle verticle,
DeploymentOptions options)
Like
RxHelper.deployVerticle(Vertx, Verticle) , but DeploymentOptions are provided to configure the
deployment. |
static Scheduler |
RxHelper.scheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions are executed on the event loop of the current context. |
static RxJavaSchedulersHook |
RxHelper.schedulerHook(Vertx vertx)
Create a scheduler hook for a
Vertx object. |
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 |
---|---|
static SqlClient |
DB2Pool.client(Vertx vertx,
DB2ConnectOptions database,
PoolOptions options)
Like
DB2Pool.client(java.lang.String) with a specific
instance. |
static SqlClient |
DB2Pool.client(Vertx vertx,
List<DB2ConnectOptions> databases,
PoolOptions options)
Like
DB2Pool.client(java.lang.String) with a specific
instance. |
static SqlClient |
DB2Pool.client(Vertx vertx,
String connectionUri)
Like
DB2Pool.client(java.lang.String) with default options. |
static SqlClient |
DB2Pool.client(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static void |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions)
Create a connection to DB2 server with the given
connectOptions . |
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)
|
static void |
DB2Connection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<DB2Connection>> handler)
|
static DB2Pool |
DB2Pool.pool(Vertx vertx,
DB2ConnectOptions database,
PoolOptions options)
Like
DB2Pool.pool(java.lang.String) with a specific
instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
List<DB2ConnectOptions> databases,
PoolOptions options)
Like
DB2Pool.pool(java.lang.String) with a specific
instance. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri)
Like
DB2Pool.pool(java.lang.String) with default options. |
static DB2Pool |
DB2Pool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static Single<DB2Connection> |
DB2Connection.rxConnect(Vertx vertx,
DB2ConnectOptions connectOptions)
Create a connection to DB2 server with the given
connectOptions . |
static Single<DB2Connection> |
DB2Connection.rxConnect(Vertx vertx,
String connectionUri)
|
Modifier and Type | Method and Description |
---|---|
static VertxContextPRNG |
VertxContextPRNG.current(Vertx vertx)
Get or create a secure non blocking random number generator using the current vert.x instance.
|
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.
|
static JDBCHashStrategy |
JDBCHashStrategy.createPBKDF2(Vertx vertx)
Deprecated.
|
static JDBCHashStrategy |
JDBCHashStrategy.createSHA512(Vertx vertx)
Deprecated.
|
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 |
---|---|
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 |
GiteeAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Gitee
|
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 |
GiteeAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Gitee
|
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 void |
SalesforceAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
IBMCloudAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
GoogleAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AzureADAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
KeycloakAuth.discover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
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.
|
static Single<OAuth2Auth> |
SalesforceAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
IBMCloudAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
GoogleAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
AzureADAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
OpenIDConnectAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
KeycloakAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Single<OAuth2Auth> |
AmazonCognitoAuth.rxDiscover(Vertx vertx,
OAuth2Options config)
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,
ShiroAuthOptions options)
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 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. |
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 |
---|---|
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.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.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.rxjava.core.Vertx, io.vertx.ext.mail.MailConfig, java.lang.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.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.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 ShellServer |
ShellServer.create(Vertx vertx)
Create a new shell server with specific options.
|
static ShellService |
ShellService.create(Vertx vertx)
Like
ShellService.create(io.vertx.rxjava.core.Vertx) , 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 CommandRegistry |
CommandRegistry.getShared(Vertx vertx)
Get the shared registry for the 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 |
---|---|
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 |
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)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
|
static void |
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.
|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.rxCreate(Vertx vertx,
String url)
Deprecated.
|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.rxCreate(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
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 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 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(io.vertx.rxjava.core.Vertx, io.vertx.core.json.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)
Deprecated.
|
static JadeTemplateEngine |
JadeTemplateEngine.create(Vertx vertx,
String extension)
Deprecated.
|
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 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)
Deprecated.
|
static SchemaRouter |
SchemaRouter.create(Vertx vertx,
SchemaRouterOptions schemaRouterOptions)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static KafkaAdminClient |
KafkaAdminClient.create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaConsumer 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> 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
|
Modifier and Type | Method and Description |
---|---|
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.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,
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 |
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 |
MSSQLConnection.connect(Vertx vertx,
MSSQLConnectOptions connectOptions)
Create a connection to SQL Server with the given
connectOptions . |
static void |
MSSQLConnection.connect(Vertx vertx,
MSSQLConnectOptions connectOptions,
Handler<AsyncResult<MSSQLConnection>> handler)
Create a connection to SQL Server with the given
connectOptions . |
static void |
MSSQLConnection.connect(Vertx vertx,
String connectionUri)
|
static void |
MSSQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MSSQLConnection>> handler)
|
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
List<MSSQLConnectOptions> databases,
PoolOptions options)
Like
MSSQLPool.pool(java.lang.String) with a specific instance. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
MSSQLConnectOptions database,
PoolOptions options)
Like
MSSQLPool.pool(java.lang.String) with a specific instance. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
String connectionUri)
Like
MSSQLPool.pool(java.lang.String) with default options. |
static MSSQLPool |
MSSQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static Single<MSSQLConnection> |
MSSQLConnection.rxConnect(Vertx vertx,
MSSQLConnectOptions connectOptions)
Create a connection to SQL Server with the given
connectOptions . |
static Single<MSSQLConnection> |
MSSQLConnection.rxConnect(Vertx vertx,
String connectionUri)
|
Modifier and Type | Method and Description |
---|---|
static SqlClient |
MySQLPool.client(Vertx vertx,
List<MySQLConnectOptions> mySQLConnectOptions,
PoolOptions options)
Like
MySQLPool.client(java.lang.String) with a specific instance. |
static SqlClient |
MySQLPool.client(Vertx vertx,
MySQLConnectOptions connectOptions,
PoolOptions poolOptions)
Like
MySQLPool.client(java.lang.String) with a specific instance. |
static SqlClient |
MySQLPool.client(Vertx vertx,
String connectionUri)
Like
MySQLPool.client(java.lang.String) with a default poolOptions . |
static SqlClient |
MySQLPool.client(Vertx vertx,
String connectionUri,
PoolOptions poolOptions)
|
static void |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions)
Create a connection to MySQL server with the given
connectOptions . |
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)
|
static void |
MySQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MySQLConnection>> handler)
|
static MySQLPool |
MySQLPool.pool(Vertx vertx,
List<MySQLConnectOptions> databases,
PoolOptions options)
Like
MySQLPool.pool(java.lang.String) with a specific instance. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
MySQLConnectOptions database,
PoolOptions options)
Like
MySQLPool.pool(java.lang.String) with a specific instance. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri)
Like
MySQLPool.pool(java.lang.String) with default options. |
static MySQLPool |
MySQLPool.pool(Vertx vertx,
String connectionUri,
PoolOptions options)
|
static Single<MySQLConnection> |
MySQLConnection.rxConnect(Vertx vertx,
MySQLConnectOptions connectOptions)
Create a connection to MySQL server with the given
connectOptions . |
static Single<MySQLConnection> |
MySQLConnection.rxConnect(Vertx vertx,
String connectionUri)
|
Modifier and Type | Method and Description |
---|---|
static void |
OracleConnection.connect(Vertx vertx,
io.vertx.oracleclient.OracleConnectOptions connectOptions)
Create a connection to Oracle with the given
connectOptions . |
static void |
OracleConnection.connect(Vertx vertx,
io.vertx.oracleclient.OracleConnectOptions connectOptions,
Handler<AsyncResult<OracleConnection>> handler)
Create a connection to Oracle with the given
connectOptions . |
static OraclePool |
OraclePool.pool(Vertx vertx,
io.vertx.oracleclient.OracleConnectOptions connectOptions,
PoolOptions poolOptions)
Like
OraclePool.pool(io.vertx.oracleclient.OracleConnectOptions, io.vertx.sqlclient.PoolOptions) with a specific instance. |
static Single<OracleConnection> |
OracleConnection.rxConnect(Vertx vertx,
io.vertx.oracleclient.OracleConnectOptions connectOptions)
Create a connection to Oracle with the given
connectOptions . |
Modifier and Type | Method and Description |
---|---|
static PgSubscriber |
PgSubscriber.subscriber(Vertx vertx,
PgConnectOptions options)
Create a subscriber.
|
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx)
Create and return a client configured with the default options.
|
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 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 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 |
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 | Method and Description |
---|---|
static Pool |
Pool.pool(Vertx vertx,
SqlConnectOptions database,
PoolOptions options)
Create a connection pool to the
database with the given options . |
Copyright © 2023 Eclipse. All rights reserved.