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) |
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 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 . |
Modifier and Type | Field and Description |
---|---|
protected Vertx |
AbstractVerticle.vertx |
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.exceptionHandler(Handler<Throwable> handler)
Set a default exception handler for
Context , set on 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 Observable<Vertx> |
Vertx.clusteredVertxObservable(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.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 AsyncSQLClient |
MySQLClient.createNonShared(Vertx vertx,
JsonObject config)
Create a MySQL client which maintains its own pool.
|
static AsyncSQLClient |
PostgreSQLClient.createNonShared(Vertx vertx,
JsonObject config)
Create a PostgreSQL client which maintains its own pool.
|
static AsyncSQLClient |
MySQLClient.createShared(Vertx vertx,
JsonObject config)
Like
MySQLClient.createShared(io.vertx.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default pool name |
static AsyncSQLClient |
PostgreSQLClient.createShared(Vertx vertx,
JsonObject config)
Like
PostgreSQLClient.createShared(io.vertx.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default 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
|
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.
|
Modifier and Type | Method and Description |
---|---|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JsonObject config)
Create a JWT auth provider
|
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.create(Vertx vertx,
OAuth2FlowType flow,
OAuth2ClientOptions config)
Create a OAuth2 auth provider
|
static OAuth2Auth |
OAuth2Auth.createKeycloak(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2 auth provider
|
Modifier and Type | Method and Description |
---|---|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthOptions options)
Create a Shiro auth provider
|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthRealmType realmType,
JsonObject config)
Create a Shiro auth provider
|
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 JDBCClient |
JDBCClient.createNonShared(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 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)
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 data source with any other Mongo clients created with the same
pool name
|
Modifier and Type | Method and Description |
---|---|
static MongoClient |
MongoClient.createNonShared(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 |
StompClient.vertx() |
Vertx |
StompServer.vertx() |
Modifier and Type | Method and Description |
---|---|
static Destination |
Destination.bridge(Vertx vertx,
BridgeOptions options) |
static StompClient |
StompClient.create(Vertx vertx)
Creates a
StompClient using the default implementation. |
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 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 vertx argument. |
TestCompletion |
TestSuite.run(Vertx vertx,
TestOptions options)
Run the testsuite with the specified
options and the specified vertx instance.
The test suite will be executed on the event loop provided by the vertx argument when
TestOptions is not set to false . |
Modifier and Type | Method and Description |
---|---|
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
Handler<TestSuiteReport> reporter) |
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
ReportingOptions options)
Create a message handler reporting with the specified options.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
RoutingContext.vertx() |
Modifier and Type | Method and Description |
---|---|
static Router |
Router.router(Vertx vertx)
Create a router
|
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
|
static void |
SockJSHandler.installTestApplications(Router router,
Vertx vertx)
Install SockJS test applications on a router - used when running the SockJS test suite
|
Modifier and Type | Method and Description |
---|---|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx)
Create a session store
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx)
Create a session store
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
long retryTimeout)
Create a session store.
The retry timeout value, configures how long the session handler will retry to get a session from the store
when it is not found.
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName)
Create a session store
|
static ClusteredSessionStore |
ClusteredSessionStore.create(Vertx vertx,
String sessionMapName,
long retryTimeout)
Create a session store.
The retry timeout value, configures how long the session handler will retry to get a session from the store
when it is not found.
|
static LocalSessionStore |
LocalSessionStore.create(Vertx vertx,
String sessionMapName,
long reaperInterval)
Create a session store
|
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
static RedisClient |
RedisClient.create(Vertx vertx) |
static RedisClient |
RedisClient.create(Vertx vertx,
RedisOptions config) |
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 |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> future)
Starts the bridge.
|
void |
ServiceImporter.stop(Vertx vertx,
ServicePublisher publisher,
Future<Void> future)
Stops the bridge.
|
Copyright © 2016. All rights reserved.