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 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 |
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 |
---|---|
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 |
AbstractVerticle.getVertx()
Get the Vert.x instance
|
Vertx |
Verticle.getVertx()
Get a reference to the Vert.x instance that deployed this verticle
|
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.handleDeployFailed(Vertx vertx,
String mainVerticle,
DeploymentOptions deploymentOptions,
Throwable cause)
A deployment failure has been encountered.
|
void |
AbstractVerticle.init(Vertx vertx,
Context context)
Initialise the verticle.
|
void |
Verticle.init(Vertx vertx,
Context context)
Initialise the verticle with the Vert.x instance and the context.
|
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.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
VertxFactory.vertx() |
Vertx |
VertxFactory.vertx(VertxOptions options) |
Modifier and Type | Method and Description |
---|---|
default void |
VerticleFactory.init(Vertx vertx)
Initialise the factory
|
VertxMetrics |
VertxMetricsFactory.metrics(Vertx vertx,
VertxOptions options)
Create a new
VertxMetrics object.
No specific thread and context can be expected when this method is called. |
Modifier and Type | Method and Description |
---|---|
void |
VertxFactory.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterManager.setVertx(Vertx vertx) |
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.core.Vertx, JsonObject, String) but with the default pool name |
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,
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 |
---|---|
AuthProvider |
AuthOptions.createProvider(Vertx vertx)
Create the suitable provider for this option.
|
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 JDBCAuth |
JDBCAuth.create(Vertx vertx,
JDBCClient client)
Create a JDBC auth provider implementation
|
JDBCAuth |
JDBCAuthOptions.createProvider(Vertx vertx) |
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 |
---|---|
MongoAuth |
MongoAuthOptions.createProvider(Vertx vertx) |
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)
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 |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Gtihub
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Heroku
|
static OAuth2Auth |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret)
Create a OAuth2Auth provider for Twitter
|
static OAuth2Auth |
BoxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for App.net
|
static OAuth2Auth |
DropboxAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
FacebookAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Facebook
|
static OAuth2Auth |
FoursquareAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
GithubAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Gtihub
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google
|
static OAuth2Auth |
HerokuAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
InstagramAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Instagram
|
static OAuth2Auth |
LinkedInAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for LinkedIn
|
static OAuth2Auth |
LiveAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for live.com
|
static OAuth2Auth |
MailchimpAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
SalesforceAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Salesforce
|
static OAuth2Auth |
SoundcloudAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
StripeAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Dropbox
|
static OAuth2Auth |
TwitterAuth.create(Vertx vertx,
String clientId,
String clientSecret,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Twitter
|
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)
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,
HttpClientOptions httpClientOptions)
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
|
Modifier and Type | Method and Description |
---|---|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
org.apache.shiro.realm.Realm realm)
Create a Shiro auth provider
|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthOptions options)
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 |
---|---|
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
static TcpEventBusBridge |
TcpEventBusBridge_GroovyStaticExtension.create(TcpEventBusBridge j_receiver,
Vertx vertx,
Map<String,Object> options) |
static TcpEventBusBridge |
TcpEventBusBridge_GroovyStaticExtension.create(TcpEventBusBridge j_receiver,
Vertx vertx,
Map<String,Object> options,
Map<String,Object> netServerOptions) |
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.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.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 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.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 data source with any other Mongo clients created with the same
pool name
|
Constructor and Description |
---|
MailServiceVertxEBProxy(Vertx vertx,
String address) |
MailServiceVertxEBProxy(Vertx vertx,
String address,
DeliveryOptions options) |
MailServiceVertxProxyHandler(Vertx vertx,
MailService service) |
MailServiceVertxProxyHandler(Vertx vertx,
MailService service,
boolean topLevel,
long timeoutSeconds) |
MailServiceVertxProxyHandler(Vertx vertx,
MailService service,
long timeoutInSecond) |
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.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 |
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 |
---|---|
void |
TestCase.awaitSuccess(Vertx vertx)
Assert the test case passes and block until it is executed.
|
void |
TestCase.awaitSuccess(Vertx vertx,
long timeout,
TimeUnit unit)
Assert the test case passes and block until it is executed.
|
TestCompletion |
TestSuite.run(Vertx vertx)
Run the testsuite with the default options and the specified
vertx instance.
The test suite will be executed on the event loop provided by the vertx argument. |
TestCompletion |
TestSuite.run(Vertx vertx,
TestOptions options)
Run the testsuite with the specified
options and the specified vertx instance.
The test suite will be executed on the event loop provided by the vertx argument when
TestOptions.setUseEventLoop(Boolean) is not set to false . |
Modifier and Type | Method and Description |
---|---|
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
Handler<TestSuiteReport> reporter) |
static EventBusCollector |
EventBusCollector.create(Vertx vertx,
ReportingOptions options)
Create a message handler reporting with the specified options.
|
Modifier and Type | Method and Description |
---|---|
Vertx |
RunTestOnContext.vertx()
Retrieves the current Vert.x instance, this value varies according to the test life cycle.
|
Constructor and Description |
---|
RunTestOnContext(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 |
---|---|
static Reporter<?> |
Reporter.reporter(Vertx vertx,
ReportOptions options) |
Reporter |
ReporterFactory.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 WebClient |
WebClient.create(Vertx vertx)
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
|
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 PebbleTemplateEngine |
PebbleTemplateEngine.create(Vertx vertx)
Create a template engine using defaults
|
Modifier and Type | Method and Description |
---|---|
static AmqpBridge |
AmqpBridge_GroovyStaticExtension.create(AmqpBridge j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static CircuitBreaker |
CircuitBreaker_GroovyStaticExtension.create(CircuitBreaker j_receiver,
String name,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static ConfigRetriever |
ConfigRetriever_GroovyStaticExtension.create(ConfigRetriever j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static Vertx |
Vertx_GroovyStaticExtension.vertx(Vertx j_receiver,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static void |
Vertx_GroovyStaticExtension.clusteredVertx(Vertx j_receiver,
Map<String,Object> options,
Handler<AsyncResult<Vertx>> resultHandler) |
static DatagramSocket |
Vertx_GroovyExtension.createDatagramSocket(Vertx j_receiver,
Map<String,Object> options) |
static HttpClient |
Vertx_GroovyExtension.createHttpClient(Vertx j_receiver,
Map<String,Object> options) |
static HttpServer |
Vertx_GroovyExtension.createHttpServer(Vertx j_receiver,
Map<String,Object> options) |
static NetClient |
Vertx_GroovyExtension.createNetClient(Vertx j_receiver,
Map<String,Object> options) |
static NetServer |
Vertx_GroovyExtension.createNetServer(Vertx j_receiver,
Map<String,Object> options) |
static void |
Vertx_GroovyExtension.deployVerticle(Vertx j_receiver,
String name,
Map<String,Object> options) |
static void |
Vertx_GroovyExtension.deployVerticle(Vertx j_receiver,
String name,
Map<String,Object> options,
Handler<AsyncResult<String>> completionHandler) |
static <T> void |
Vertx_GroovyExtension.executeBlocking(Vertx j_receiver,
Handler<Future<Object>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<Object>> resultHandler) |
static <T> void |
Vertx_GroovyExtension.executeBlocking(Vertx j_receiver,
Handler<Future<Object>> blockingCodeHandler,
Handler<AsyncResult<Object>> resultHandler) |
static Vertx |
Vertx_GroovyStaticExtension.vertx(Vertx j_receiver,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static void |
Vertx_GroovyStaticExtension.clusteredVertx(Vertx j_receiver,
Map<String,Object> options,
Handler<AsyncResult<Vertx>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
static AsyncSQLClient |
MySQLClient_GroovyStaticExtension.createNonShared(MySQLClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static AsyncSQLClient |
PostgreSQLClient_GroovyStaticExtension.createNonShared(PostgreSQLClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static AsyncSQLClient |
MySQLClient_GroovyStaticExtension.createShared(MySQLClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static AsyncSQLClient |
MySQLClient_GroovyStaticExtension.createShared(MySQLClient j_receiver,
Vertx vertx,
Map<String,Object> config,
String poolName) |
static AsyncSQLClient |
PostgreSQLClient_GroovyStaticExtension.createShared(PostgreSQLClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static AsyncSQLClient |
PostgreSQLClient_GroovyStaticExtension.createShared(PostgreSQLClient j_receiver,
Vertx vertx,
Map<String,Object> config,
String poolName) |
Modifier and Type | Method and Description |
---|---|
static JWTAuth |
JWTAuth_GroovyStaticExtension.create(JWTAuth j_receiver,
Vertx vertx,
Map<String,Object> config) |
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
OAuth2Auth_GroovyStaticExtension.create(OAuth2Auth j_receiver,
Vertx vertx,
OAuth2FlowType flow,
Map<String,Object> config) |
static OAuth2Auth |
OAuth2Auth_GroovyStaticExtension.createKeycloak(OAuth2Auth j_receiver,
Vertx vertx,
OAuth2FlowType flow,
Map<String,Object> config) |
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
AzureADAuth_GroovyStaticExtension.create(AzureADAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
String guid,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
BoxAuth_GroovyStaticExtension.create(BoxAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
CloudFoundryAuth_GroovyStaticExtension.create(CloudFoundryAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
String uuaURL,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
DropboxAuth_GroovyStaticExtension.create(DropboxAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
FacebookAuth_GroovyStaticExtension.create(FacebookAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
FoursquareAuth_GroovyStaticExtension.create(FoursquareAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
GithubAuth_GroovyStaticExtension.create(GithubAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
GoogleAuth_GroovyStaticExtension.create(GoogleAuth j_receiver,
Vertx vertx,
Map<String,Object> serviceAccountJson) |
static OAuth2Auth |
GoogleAuth_GroovyStaticExtension.create(GoogleAuth j_receiver,
Vertx vertx,
Map<String,Object> serviceAccountJson,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
GoogleAuth_GroovyStaticExtension.create(GoogleAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
HerokuAuth_GroovyStaticExtension.create(HerokuAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
InstagramAuth_GroovyStaticExtension.create(InstagramAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
KeycloakAuth_GroovyStaticExtension.create(KeycloakAuth j_receiver,
Vertx vertx,
Map<String,Object> config) |
static OAuth2Auth |
KeycloakAuth_GroovyStaticExtension.create(KeycloakAuth j_receiver,
Vertx vertx,
Map<String,Object> config,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
KeycloakAuth_GroovyStaticExtension.create(KeycloakAuth j_receiver,
Vertx vertx,
OAuth2FlowType flow,
Map<String,Object> config) |
static OAuth2Auth |
KeycloakAuth_GroovyStaticExtension.create(KeycloakAuth j_receiver,
Vertx vertx,
OAuth2FlowType flow,
Map<String,Object> config,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
LinkedInAuth_GroovyStaticExtension.create(LinkedInAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
LiveAuth_GroovyStaticExtension.create(LiveAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
MailchimpAuth_GroovyStaticExtension.create(MailchimpAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
SalesforceAuth_GroovyStaticExtension.create(SalesforceAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
ShopifyAuth_GroovyStaticExtension.create(ShopifyAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
String shop,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
SoundcloudAuth_GroovyStaticExtension.create(SoundcloudAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
StripeAuth_GroovyStaticExtension.create(StripeAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
static OAuth2Auth |
TwitterAuth_GroovyStaticExtension.create(TwitterAuth j_receiver,
Vertx vertx,
String clientId,
String clientSecret,
Map<String,Object> httpClientOptions) |
Modifier and Type | Method and Description |
---|---|
static ShiroAuth |
ShiroAuth_GroovyStaticExtension.create(ShiroAuth j_receiver,
Vertx vertx,
Map<String,Object> options) |
static ShiroAuth |
ShiroAuth_GroovyStaticExtension.create(ShiroAuth j_receiver,
Vertx vertx,
ShiroAuthRealmType realmType,
Map<String,Object> config) |
Modifier and Type | Method and Description |
---|---|
static ConsulClient |
ConsulClient_GroovyStaticExtension.create(ConsulClient j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static JDBCClient |
JDBCClient_GroovyStaticExtension.createNonShared(JDBCClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static JDBCClient |
JDBCClient_GroovyStaticExtension.createShared(JDBCClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static JDBCClient |
JDBCClient_GroovyStaticExtension.createShared(JDBCClient j_receiver,
Vertx vertx,
Map<String,Object> config,
String dataSourceName) |
Modifier and Type | Method and Description |
---|---|
static MailClient |
MailClient_GroovyStaticExtension.createNonShared(MailClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static MailClient |
MailClient_GroovyStaticExtension.createShared(MailClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static MailClient |
MailClient_GroovyStaticExtension.createShared(MailClient j_receiver,
Vertx vertx,
Map<String,Object> config,
String poolName) |
Modifier and Type | Method and Description |
---|---|
static MongoClient |
MongoClient_GroovyStaticExtension.createNonShared(MongoClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static MongoClient |
MongoClient_GroovyStaticExtension.createShared(MongoClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
static MongoClient |
MongoClient_GroovyStaticExtension.createShared(MongoClient j_receiver,
Vertx vertx,
Map<String,Object> config,
String dataSourceName) |
Modifier and Type | Method and Description |
---|---|
static ShellServer |
ShellServer_GroovyStaticExtension.create(ShellServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
static ShellService |
ShellService_GroovyStaticExtension.create(ShellService j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static TermServer |
TermServer_GroovyStaticExtension.createHttpTermServer(TermServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
static TermServer |
TermServer_GroovyStaticExtension.createHttpTermServer(TermServer j_receiver,
Vertx vertx,
Router router,
Map<String,Object> options) |
static TermServer |
TermServer_GroovyStaticExtension.createSSHTermServer(TermServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
static TermServer |
TermServer_GroovyStaticExtension.createTelnetTermServer(TermServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static Destination |
Destination_GroovyStaticExtension.bridge(Destination j_receiver,
Vertx vertx,
Map<String,Object> options) |
static StompClient |
StompClient_GroovyStaticExtension.create(StompClient j_receiver,
Vertx vertx,
Map<String,Object> options) |
static StompServer |
StompServer_GroovyStaticExtension.create(StompServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
static StompServer |
StompServer_GroovyStaticExtension.create(StompServer j_receiver,
Vertx vertx,
NetServer net,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static TestCompletion |
TestSuite_GroovyExtension.run(TestSuite j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static EventBusCollector |
EventBusCollector_GroovyStaticExtension.create(EventBusCollector j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static SockJSHandler |
SockJSHandler_GroovyStaticExtension.create(SockJSHandler j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer_GroovyStaticExtension.create(MqttServer j_receiver,
Vertx vertx,
Map<String,Object> options) |
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient_GroovyStaticExtension.create(RabbitMQClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
Modifier and Type | Method and Description |
---|---|
static RedisClient |
RedisClient_GroovyStaticExtension.create(RedisClient j_receiver,
Vertx vertx,
Map<String,Object> config) |
Modifier and Type | Method and Description |
---|---|
static ServiceDiscovery |
ServiceDiscovery_GroovyStaticExtension.create(ServiceDiscovery j_receiver,
Vertx vertx,
Map<String,Object> options) |
static ServiceDiscovery |
ServiceDiscovery_GroovyStaticExtension.create(ServiceDiscovery j_receiver,
Vertx vertx,
Map<String,Object> options,
Handler<ServiceDiscovery> completionHandler) |
Modifier and Type | Method and Description |
---|---|
static void |
ServiceExporter_GroovyExtension.init(ServiceExporter j_receiver,
Vertx vertx,
ServicePublisher publisher,
Map<String,Object> configuration,
Future<Void> future) |
static void |
ServiceImporter_GroovyExtension.start(ServiceImporter j_receiver,
Vertx vertx,
ServicePublisher publisher,
Map<String,Object> configuration,
Future<Void> future) |
Modifier and Type | Field and Description |
---|---|
protected Vertx |
GroovyVerticle.vertx
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
GroovyVerticleFactory.init(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
Vertx |
JRubyVerticle.getVertx() |
Modifier and Type | Method and Description |
---|---|
void |
JRubyVerticleFactory.init(Vertx vertx) |
void |
JRubyVerticle.init(Vertx vertx,
Context context) |
Modifier and Type | Method and Description |
---|---|
void |
MavenVerticleFactory.init(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
static MqttServer |
MqttServer.create(Vertx vertx)
Return an MQTT server instance using default options
|
static MqttServer |
MqttServer.create(Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
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,
JsonObject config)
Deprecated.
For type safety please use
RedisClient.create(Vertx, RedisOptions) . |
static RedisClient |
RedisClient.create(Vertx vertx,
RedisOptions config) |
Modifier and Type | Method and Description |
---|---|
static rx.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 rx.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 rx.Scheduler |
RxHelper.scheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions are executed on the event loop. |
static rx.plugins.RxJavaSchedulersHook |
RxHelper.schedulerHook(Vertx vertx)
Create a scheduler hook for a
Vertx object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler. |
Constructor and Description |
---|
ContextScheduler(Vertx vertx,
boolean blocking) |
ContextScheduler(Vertx vertx,
boolean blocking,
boolean ordered) |
Modifier and Type | Method and Description |
---|---|
Vertx |
Vertx.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractVerticle.init(Vertx vertx,
Context context) |
static Vertx |
Vertx.newInstance(Vertx arg) |
Constructor and Description |
---|
Vertx(Vertx delegate) |
Modifier and Type | Method and Description |
---|---|
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
Handler<ServiceDiscovery> completionHandler)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery . |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options,
Handler<ServiceDiscovery> completionHandler)
Creates an instance of
ServiceDiscovery . |
Modifier and Type | Method and Description |
---|---|
void |
RedisBackendService.init(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
void |
ConsulServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> completion) |
Modifier and Type | Method and Description |
---|---|
void |
DockerLinksServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> completion) |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<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,
Future<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<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) |
static <T> T |
ProxyHelper.createProxy(Class<T> clazz,
Vertx vertx,
String address,
DeliveryOptions options) |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Registers a service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds) |
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds) |
Modifier and Type | Method and Description |
---|---|
void |
HazelcastClusterManager.setVertx(Vertx vertx) |
Modifier and Type | Method and Description |
---|---|
void |
IgniteClusterManager.setVertx(Vertx vertx) |
Copyright © 2017. All rights reserved.