Modifier and Type | Method and Description |
---|---|
static void |
AmqpBridgeOptionsConverter.fromJson(JsonObject json,
AmqpBridgeOptions obj) |
static void |
AmqpBridgeOptionsConverter.toJson(AmqpBridgeOptions obj,
JsonObject json) |
Constructor and Description |
---|
AmqpBridgeOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
CircuitBreakerOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static void |
CircuitBreakerOptionsConverter.fromJson(JsonObject json,
CircuitBreakerOptions obj) |
static void |
CircuitBreakerOptionsConverter.toJson(CircuitBreakerOptions obj,
JsonObject json) |
Constructor and Description |
---|
CircuitBreakerOptions(JsonObject json)
Creates a new instance of
CircuitBreakerOptions from the given json object. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
AbstractVerticle.config()
Get the configuration of the verticle.
|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
JsonObject |
DeploymentOptions.getConfig()
Get the JSON configuration that will be passed to the verticle(s) when deployed.
|
JsonObject |
DeploymentOptions.toJson()
Convert this to JSON
|
Modifier and Type | Method and Description |
---|---|
void |
Launcher.afterConfigParsed(JsonObject config)
Hook for sub-classes of
Launcher after the config has been parsed. |
void |
DeploymentOptions.fromJson(JsonObject json)
Initialise the fields of this instance from the specified JSON
|
DeploymentOptions |
DeploymentOptions.setConfig(JsonObject config)
Set the JSON configuration that will be passed to the verticle(s) when it's deployed
|
Constructor and Description |
---|
DeploymentOptions(JsonObject json)
Constructor for creating a instance from JSON
|
VertxOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a Json object representation of the Buffer
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Argument.toJson()
Exports this
Argument to its corresponding JSON representation. |
JsonObject |
Option.toJson()
Gets the json representation of this
Option . |
Constructor and Description |
---|
Argument(JsonObject json)
Creates a new instance of
Argument from the given JSON object. |
Option(JsonObject json)
Creates a new instance of
Option from the given JsonObject |
Constructor and Description |
---|
DatagramSocketOptions(JsonObject json)
Constructor to create options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
AddressResolverOptions.toJson() |
Constructor and Description |
---|
AddressResolverOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
EventBusOptions.toJson()
Builds a JSON object representing the current
EventBusOptions . |
Constructor and Description |
---|
DeliveryOptions(JsonObject json)
Create a delivery options from JSON
|
EventBusOptions(JsonObject json)
Creates a new instance of
EventBusOptions from the JSON object. |
Constructor and Description |
---|
OpenOptions(JsonObject json)
Constructor to create options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
GoAway.toJson() |
JsonObject |
Http2Settings.toJson() |
Constructor and Description |
---|
GoAway(JsonObject json) |
Http2Settings(JsonObject json)
Create an settings from JSON
|
HttpClientOptions(JsonObject json)
Constructor to create an options from JSON
|
HttpServerOptions(JsonObject json)
Create an options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonObject.clear()
Remove all the entries in this JSON object
|
JsonObject |
JsonObject.copy()
Copy the JSON object
|
JsonObject |
JsonArray.getJsonObject(int pos)
Get the JsonObject at position
pos in the array. |
JsonObject |
JsonObject.getJsonObject(String key)
Get the JsonObject value with the specified key
|
JsonObject |
JsonObject.getJsonObject(String key,
JsonObject def)
Like
getJsonObject(String) but specifying a default value to return if there is no entry. |
JsonObject |
JsonObject.mergeIn(JsonObject other)
Merge in another JSON object.
|
JsonObject |
JsonObject.put(String key,
Boolean value)
Put a Boolean into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
byte[] value)
Put a byte[] into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
CharSequence value)
Put an CharSequence into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Double value)
Put a Double into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Enum value)
Put an Enum into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Float value)
Put a Float into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
java.time.Instant value)
Put a Instant into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Integer value)
Put an Integer into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
JsonArray value)
Put a JSON array into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
JsonObject value)
Put another JSON object into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Long value)
Put a Long into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
Object value)
Put an Object into the JSON object with the specified key.
|
JsonObject |
JsonObject.put(String key,
String value)
Put a String into the JSON object with the specified key.
|
JsonObject |
JsonObject.putNull(String key)
Put a null value into the JSON object with the specified key.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArray.add(JsonObject value)
Add a JSON object to the JSON array.
|
JsonObject |
JsonObject.getJsonObject(String key,
JsonObject def)
Like
getJsonObject(String) but specifying a default value to return if there is no entry. |
JsonObject |
JsonObject.mergeIn(JsonObject other)
Merge in another JSON object.
|
JsonObject |
JsonObject.put(String key,
JsonObject value)
Put another JSON object into the JSON object with the specified key.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsOptions.toJson() |
Constructor and Description |
---|
MetricsOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JksOptions.toJson() |
JsonObject |
OpenSSLEngineOptions.toJson() |
Constructor and Description |
---|
ClientOptionsBase(JsonObject json)
Create options from some JSON
|
JdkSSLEngineOptions(JsonObject json) |
JksOptions(JsonObject json)
Create options from JSON
|
NetClientOptions(JsonObject json)
Create options from JSON
|
NetServerOptions(JsonObject json)
Create some options from JSON
|
NetworkOptions(JsonObject json)
Constructor from JSON
|
OpenSSLEngineOptions(JsonObject json) |
PemKeyCertOptions(JsonObject json)
Create options from JSON
|
PemTrustOptions(JsonObject json)
Create options from JSON
|
PfxOptions(JsonObject json)
Create options from JSON
|
ProxyOptions(JsonObject json)
Create options from JSON.
|
TCPSSLOptions(JsonObject json)
Create options from JSON
|
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 |
---|---|
JsonObject |
User.principal()
Get the underlying principal for the User.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JDBCAuthOptions.getConfig() |
Modifier and Type | Method and Description |
---|---|
static void |
JDBCAuthOptionsConverter.fromJson(JsonObject json,
JDBCAuthOptions obj) |
JDBCAuthOptions |
JDBCAuthOptions.setConfig(JsonObject config)
The configuration of the JDBC client: refer to the Vert.x JDBC Client configuration.
|
static void |
JDBCAuthOptionsConverter.toJson(JDBCAuthOptions obj,
JsonObject json) |
Constructor and Description |
---|
JDBCAuthOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JWTOptions.getHeader() |
JsonObject |
JWTOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JsonObject config)
Create a JWT auth provider
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Constructor and Description |
---|
JWTOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MongoAuthOptions.getConfig() |
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Creates an instance of MongoAuth by using the given
MongoClient and configuration object. |
static void |
MongoAuthOptionsConverter.fromJson(JsonObject json,
MongoAuthOptions obj) |
MongoAuthOptions |
MongoAuthOptions.setConfig(JsonObject config)
The mongo client configuration: see Mongo Client documentation.
|
static void |
MongoAuthOptionsConverter.toJson(MongoAuthOptions obj,
JsonObject json) |
Constructor and Description |
---|
MongoAuthOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OAuth2ClientOptions.getHeaders() |
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.api(HttpMethod method,
String path,
JsonObject params,
Handler<AsyncResult<JsonObject>> handler)
Call OAuth2 APIs.
|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Generate a redirect URL to the authN/Z backend.
|
static OAuth2Auth |
OAuth2Auth.createKeycloak(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2 auth provider
|
static void |
OAuth2ClientOptionsConverter.fromJson(JsonObject json,
OAuth2ClientOptions obj) |
void |
OAuth2Auth.getToken(JsonObject params,
Handler<AsyncResult<AccessToken>> handler)
Returns the Access Token object.
|
OAuth2ClientOptions |
OAuth2ClientOptions.setHeaders(JsonObject headers) |
static void |
OAuth2ClientOptionsConverter.toJson(OAuth2ClientOptions obj,
JsonObject json) |
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.api(HttpMethod method,
String path,
JsonObject params,
Handler<AsyncResult<JsonObject>> handler)
Call OAuth2 APIs.
|
Constructor and Description |
---|
OAuth2ClientOptions(JsonObject json)
Constructor to create an options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ShiroAuthOptions.getConfig() |
Modifier and Type | Method and Description |
---|---|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthRealmType realmType,
JsonObject config)
Deprecated.
|
static void |
ShiroAuthOptionsConverter.fromJson(JsonObject json,
ShiroAuthOptions obj) |
ShiroAuthOptions |
ShiroAuthOptions.setConfig(JsonObject config)
Set the Shiro auth config.
|
static void |
ShiroAuthOptionsConverter.toJson(ShiroAuthOptions obj,
JsonObject json) |
Constructor and Description |
---|
ShiroAuthOptions(JsonObject json) |
Modifier and Type | Field and Description |
---|---|
static JsonObject |
PermittedOptions.DEFAULT_MATCH
The default permitted match :
null . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
PermittedOptions.getMatch() |
JsonObject |
BridgeOptions.toJson()
Serializes the current
BridgeOptions to JSON. |
JsonObject |
PermittedOptions.toJson()
Serializes the current instance of
PermittedOptions to JSON. |
Modifier and Type | Method and Description |
---|---|
static void |
BridgeOptionsConverter.fromJson(JsonObject json,
BridgeOptions obj) |
static void |
PermittedOptionsConverter.fromJson(JsonObject json,
PermittedOptions obj) |
PermittedOptions |
PermittedOptions.setMatch(JsonObject match)
This allows you to allow messages based on their structure.
|
static void |
BridgeOptionsConverter.toJson(BridgeOptions obj,
JsonObject json) |
static void |
PermittedOptionsConverter.toJson(PermittedOptions obj,
JsonObject json) |
Constructor and Description |
---|
BridgeOptions(JsonObject json)
Creates a new instance of
BridgeOptions from its JSON representation. |
PermittedOptions(JsonObject json)
Creates a new instance of
PermittedOptions from its JSON representation. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
Constructor and Description |
---|
DropwizardMetricsOptions(JsonObject json)
Create an instance from a
JsonObject |
Match(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
VertxHawkularOptions.getHttpHeaders() |
Modifier and Type | Method and Description |
---|---|
static void |
AuthenticationOptionsConverter.fromJson(JsonObject json,
AuthenticationOptions obj) |
static void |
VertxHawkularOptionsConverter.fromJson(JsonObject json,
VertxHawkularOptions obj) |
VertxHawkularOptions |
VertxHawkularOptions.setHttpHeaders(JsonObject httpHeaders)
Set specific headers to include in HTTP requests.
|
static void |
AuthenticationOptionsConverter.toJson(AuthenticationOptions obj,
JsonObject json) |
static void |
VertxHawkularOptionsConverter.toJson(VertxHawkularOptions obj,
JsonObject json) |
Constructor and Description |
---|
AuthenticationOptions(JsonObject json) |
VertxHawkularOptions(JsonObject json) |
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.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 |
---|---|
DataSource |
DataSourceProvider.getDataSource(JsonObject config) |
int |
DataSourceProvider.maximumPoolSize(DataSource dataSource,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MailAttachment.toJson()
convert this object to JSON representation
|
JsonObject |
MailConfig.toJson()
convert config object to Json representation
|
JsonObject |
MailMessage.toJson()
convert the mail message to Json representation
|
JsonObject |
MailResult.toJson() |
Modifier and Type | Method and Description |
---|---|
MessageConsumer<JsonObject> |
MailServiceVertxProxyHandler.registerHandler(String address) |
Modifier and Type | Method and Description |
---|---|
void |
MailServiceVertxProxyHandler.handle(Message<JsonObject> msg) |
Constructor and Description |
---|
MailAttachment(JsonObject json)
create a MailAttachment object from a JsonObject representation
|
MailConfig(JsonObject config)
construct config object from Json representation
|
MailMessage(JsonObject json)
construct object from a JsonObject representation
|
MailResult(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MongoClientUpdateResult.getDocUpsertedId()
Get the document id that's upserted
|
JsonObject |
FindOptions.getFields()
Get the fields
|
JsonObject |
FindOptions.getSort()
Get the sort document
|
JsonObject |
FindOptions.toJson()
Convert to JSON
|
JsonObject |
MongoClientDeleteResult.toJson()
Convert to JSON
|
JsonObject |
MongoClientUpdateResult.toJson()
Convert to JSON
|
JsonObject |
UpdateOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
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
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findBatch(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection.
|
MongoClient |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection, specifying options.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
FindOptions |
FindOptions.setFields(JsonObject fields)
Set the fields
|
FindOptions |
FindOptions.setSort(JsonObject sort)
Set the sort document
|
MongoClient |
MongoClient.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonObject>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findBatch(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection.
|
MongoClient |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection, specifying options.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Constructor and Description |
---|
FindOptions(JsonObject json)
Constructor from JSON
|
MongoClientDeleteResult(JsonObject mongoClientDeleteResultJson)
Constructor form JSON
|
MongoClientUpdateResult(JsonObject mongoClientUpdateResultJson)
Constructor from JSON
|
MongoClientUpdateResult(long docMatched,
JsonObject docUpsertedId,
long docModified)
Constructor to specify the status of the operation.
|
UpdateOptions(JsonObject json)
Constructor from JSON
|
Modifier and Type | Method and Description |
---|---|
static void |
ShellServerOptionsConverter.fromJson(JsonObject json,
ShellServerOptions obj) |
static void |
ShellServiceOptionsConverter.fromJson(JsonObject json,
ShellServiceOptions obj) |
static void |
ShellServerOptionsConverter.toJson(ShellServerOptions obj,
JsonObject json) |
static void |
ShellServiceOptionsConverter.toJson(ShellServiceOptions obj,
JsonObject json) |
Constructor and Description |
---|
ShellServerOptions(JsonObject json) |
ShellServiceOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
static void |
HttpTermOptionsConverter.fromJson(JsonObject json,
HttpTermOptions obj) |
static void |
SSHTermOptionsConverter.fromJson(JsonObject json,
SSHTermOptions obj) |
static void |
TelnetTermOptionsConverter.fromJson(JsonObject json,
TelnetTermOptions obj) |
static void |
HttpTermOptionsConverter.toJson(HttpTermOptions obj,
JsonObject json) |
static void |
SSHTermOptionsConverter.toJson(SSHTermOptions obj,
JsonObject json) |
static void |
TelnetTermOptionsConverter.toJson(TelnetTermOptions obj,
JsonObject json) |
Constructor and Description |
---|
HttpTermOptions(JsonObject json) |
SSHTermOptions(JsonObject json) |
TelnetTermOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ResultSet.toJson()
Convert to JSON
|
JsonObject |
UpdateResult.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
List<JsonObject> |
ResultSet.getRows()
Get the rows - each row represented as a JsonObject where the keys are the column names and the values are
the column values.
|
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetConverter.fromJson(JsonObject json,
ResultSet obj) |
static void |
UpdateResultConverter.fromJson(JsonObject json,
UpdateResult obj) |
static void |
ResultSetConverter.toJson(ResultSet obj,
JsonObject json) |
static void |
UpdateResultConverter.toJson(UpdateResult obj,
JsonObject json) |
Constructor and Description |
---|
ResultSet(JsonObject json)
Create a result-set from JSON
|
UpdateResult(JsonObject json)
Constructor from JSON
|
Modifier and Type | Field and Description |
---|---|
static JsonObject |
StompOptions.DEFAULT_STOMP_HEARTBEAT |
Modifier and Type | Method and Description |
---|---|
JsonObject |
StompClientOptions.getHeartbeat()
Gets the heartbeat configuration.
|
JsonObject |
StompServerOptions.getHeartbeat()
Gets the heartbeat configuration.
|
JsonObject |
BridgeOptions.toJson() |
JsonObject |
Frame.toJson() |
JsonObject |
StompClientOptions.toJson() |
JsonObject |
StompServerOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static Frame.Heartbeat |
Frame.Heartbeat.create(JsonObject json)
Creates an instance of
Frame.Heartbeat from the JSON configuration provides in the
client / server options. |
static void |
FrameConverter.fromJson(JsonObject json,
Frame obj) |
static void |
StompClientOptionsConverter.fromJson(JsonObject json,
StompClientOptions obj) |
static void |
StompServerOptionsConverter.fromJson(JsonObject json,
StompServerOptions obj) |
StompClientOptions |
StompClientOptions.setHeartbeat(JsonObject heartbeat)
Sets the heartbeat configuration.
|
StompServerOptions |
StompServerOptions.setHeartbeat(JsonObject heartbeat)
Sets the heartbeat configuration.
|
static void |
FrameConverter.toJson(Frame obj,
JsonObject json) |
static void |
StompClientOptionsConverter.toJson(StompClientOptions obj,
JsonObject json) |
static void |
StompServerOptionsConverter.toJson(StompServerOptions obj,
JsonObject json) |
Constructor and Description |
---|
BridgeOptions(JsonObject json) |
Frame(JsonObject json)
Creates a new instance of
Frame from its JSON representation. |
StompClientOptions(JsonObject json)
Creates an instance from a
JsonObject . |
StompServerOptions(JsonObject json)
Create an instance from a
JsonObject . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
TestOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static void |
TestOptionsConverter.fromJson(JsonObject json,
TestOptions obj) |
static void |
TestOptionsConverter.toJson(TestOptions obj,
JsonObject json) |
Constructor and Description |
---|
TestOptions(JsonObject json)
Create a new options from the specified json.
|
Modifier and Type | Method and Description |
---|---|
Handler<Message<JsonObject>> |
EventBusCollector.asMessageHandler() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ReportingOptions.toJson() |
JsonObject |
ReportOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static void |
ReportingOptionsConverter.fromJson(JsonObject json,
ReportingOptions obj) |
static void |
ReportOptionsConverter.fromJson(JsonObject json,
ReportOptions obj) |
static void |
ReportingOptionsConverter.toJson(ReportingOptions obj,
JsonObject json) |
static void |
ReportOptionsConverter.toJson(ReportOptions obj,
JsonObject json) |
Constructor and Description |
---|
ReportingOptions(JsonObject json)
Create a new options from the specified json.
|
ReportOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RoutingContext.getBodyAsJson() |
Modifier and Type | Field and Description |
---|---|
static JsonObject |
PermittedOptions.DEFAULT_MATCH
The default permitted match :
null . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
PermittedOptions.getMatch() |
JsonObject |
BridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
JsonObject |
BridgeEvent.rawMessage()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PermittedOptions |
PermittedOptions.setMatch(JsonObject match)
This allows you to allow messages based on their structure.
|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Constructor and Description |
---|
BridgeOptions(JsonObject json)
Constructor from JSON
|
PermittedOptions(JsonObject json) |
SockJSHandlerOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
JsonObject message,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.basicAck(long deliveryTag,
boolean multiple,
Handler<AsyncResult<JsonObject>> resultHandler)
Acknowledge one or several received messages.
|
void |
RabbitMQClient.basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<JsonObject>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
void |
RabbitMQClient.basicNack(long deliveryTag,
boolean multiple,
boolean requeue,
Handler<AsyncResult<JsonObject>> resultHandler)
Reject one or several received messages.
|
void |
RabbitMQClient.messageCount(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Returns the number of messages in a queue ready to be delivered.
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Handler<AsyncResult<JsonObject>> resultHandler)
Declare a queue
|
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
void |
RabbitMQClient.queueDelete(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue, without regard for whether it is in use or has messages on it
|
void |
RabbitMQClient.queueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RedisOptions.toJSON() |
Modifier and Type | Method and Description |
---|---|
static RedisClient |
RedisClient.create(Vertx vertx,
JsonObject config)
Deprecated.
For type safety please use
RedisClient.create(Vertx, RedisOptions) . |
RedisClient |
RedisClient.hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisTransaction |
RedisTransaction.hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisClient |
RedisClient.mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisTransaction |
RedisTransaction.mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisClient |
RedisClient.msetnx(JsonObject keyvals,
Handler<AsyncResult<Long>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
RedisTransaction |
RedisTransaction.msetnx(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.hgetall(String key,
Handler<AsyncResult<JsonObject>> handler)
Get all the fields and values in a hash
|
RedisClient |
RedisClient.info(Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.infoSection(String section,
Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
Constructor and Description |
---|
RedisOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
GeoMember.toJson() |
JsonObject |
GeoRadiusOptions.toJson() |
JsonObject |
KillFilter.toJson() |
JsonObject |
LimitOptions.toJson() |
JsonObject |
MigrateOptions.toJson() |
JsonObject |
RangeLimitOptions.toJson() |
JsonObject |
ScanOptions.toJson() |
JsonObject |
SetOptions.toJson() |
JsonObject |
SortOptions.toJson() |
Constructor and Description |
---|
GeoMember(JsonObject obj) |
GeoRadiusOptions(JsonObject obj) |
KillFilter(JsonObject json) |
LimitOptions(JsonObject obj) |
MigrateOptions(JsonObject json) |
RangeLimitOptions(JsonObject obj) |
ScanOptions(JsonObject obj) |
SetOptions(JsonObject json) |
SortOptions(JsonObject obj) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a Json object representation of the Buffer
|
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 |
---|---|
JsonObject |
User.principal()
Get the underlying principal for the User.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
Observable<User> |
AuthProvider.authenticateObservable(JsonObject authInfo)
Authenticate a user.
|
Modifier and Type | Method and Description |
---|---|
static JWTAuth |
JWTAuth.create(Vertx vertx,
JsonObject config)
Create a JWT auth provider
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Creates an instance of MongoAuth by using the given and configuration object.
|
Modifier and Type | Method and Description |
---|---|
Observable<JsonObject> |
OAuth2Auth.apiObservable(HttpMethod method,
String path,
JsonObject params)
Call OAuth2 APIs.
|
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.api(HttpMethod method,
String path,
JsonObject params,
Handler<AsyncResult<JsonObject>> handler)
Call OAuth2 APIs.
|
Observable<JsonObject> |
OAuth2Auth.apiObservable(HttpMethod method,
String path,
JsonObject params)
Call OAuth2 APIs.
|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Generate a redirect URL to the authN/Z backend.
|
static OAuth2Auth |
OAuth2Auth.createKeycloak(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2 auth provider
|
void |
OAuth2Auth.getToken(JsonObject params,
Handler<AsyncResult<AccessToken>> handler)
Returns the Access Token object.
|
Observable<AccessToken> |
OAuth2Auth.getTokenObservable(JsonObject params)
Returns the Access Token object.
|
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.api(HttpMethod method,
String path,
JsonObject params,
Handler<AsyncResult<JsonObject>> handler)
Call OAuth2 APIs.
|
Modifier and Type | Method and Description |
---|---|
static ShiroAuth |
ShiroAuth.create(Vertx vertx,
ShiroAuthRealmType realmType,
JsonObject config)
Create a Shiro auth provider
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
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 |
---|---|
Observable<JsonObject> |
MongoClient.distinctBatchObservable(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Observable<JsonObject> |
MongoClient.findBatchObservable(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
Observable<JsonObject> |
MongoClient.findBatchWithOptionsObservable(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Observable<List<JsonObject>> |
MongoClient.findObservable(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Observable<JsonObject> |
MongoClient.findOneObservable(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Observable<List<JsonObject>> |
MongoClient.findWithOptionsObservable(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Observable<JsonObject> |
MongoClient.runCommandObservable(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
Observable<Long> |
MongoClient.countObservable(String collection,
JsonObject query)
Count matching documents in a collection.
|
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
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findBatch(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection.
|
Observable<JsonObject> |
MongoClient.findBatchObservable(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
MongoClient |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection, specifying options.
|
Observable<JsonObject> |
MongoClient.findBatchWithOptionsObservable(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Observable<List<JsonObject>> |
MongoClient.findObservable(String collection,
JsonObject query)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
Observable<JsonObject> |
MongoClient.findOneObservable(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
Observable<List<JsonObject>> |
MongoClient.findWithOptionsObservable(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
Observable<String> |
MongoClient.insertObservable(String collection,
JsonObject document)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
Observable<String> |
MongoClient.insertWithOptionsObservable(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection
|
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with MongoClientDeleteResult result
|
Observable<MongoClientDeleteResult> |
MongoClient.removeDocumentObservable(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with MongoClientDeleteResult result
|
Observable<MongoClientDeleteResult> |
MongoClient.removeDocumentsObservable(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
Observable<MongoClientDeleteResult> |
MongoClient.removeDocumentsWithOptionsObservable(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
Observable<MongoClientDeleteResult> |
MongoClient.removeDocumentWithOptionsObservable(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
Observable<Void> |
MongoClient.removeObservable(String collection,
JsonObject query)
Remove matching documents from a collection
|
MongoClient |
MongoClient.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection
|
Observable<Void> |
MongoClient.removeOneObservable(String collection,
JsonObject query)
Remove a single matching document from a collection
|
MongoClient |
MongoClient.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection with the specified write option
|
Observable<Void> |
MongoClient.removeOneWithOptionsObservable(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option
|
MongoClient |
MongoClient.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection with the specified write option
|
Observable<Void> |
MongoClient.removeWithOptionsObservable(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option
|
MongoClient |
MongoClient.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection
|
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
Observable<MongoClientUpdateResult> |
MongoClient.replaceDocumentsObservable(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
Observable<MongoClientUpdateResult> |
MongoClient.replaceDocumentsWithOptionsObservable(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
Observable<Void> |
MongoClient.replaceObservable(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection
|
MongoClient |
MongoClient.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection, specifying options
|
Observable<Void> |
MongoClient.replaceWithOptionsObservable(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Observable<JsonObject> |
MongoClient.runCommandObservable(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
Observable<String> |
MongoClient.saveObservable(String collection,
JsonObject document)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
Observable<String> |
MongoClient.saveWithOptionsObservable(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection
|
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
Observable<MongoClientUpdateResult> |
MongoClient.updateCollectionObservable(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
Observable<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptionsObservable(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
Observable<Void> |
MongoClient.updateObservable(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection
|
MongoClient |
MongoClient.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection, specifying options
|
Observable<Void> |
MongoClient.updateWithOptionsObservable(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonObject>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findBatch(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection.
|
MongoClient |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<JsonObject>> resultHandler)
Find matching documents in the specified collection, specifying options.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RoutingContext.getBodyAsJson() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
BridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
JsonObject |
BridgeEvent.rawMessage()
Use
BridgeEvent.getRawMessage() instead, will be removed in 3.3 |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Observable<JsonObject> |
RabbitMQClient.basicAckObservable(long deliveryTag,
boolean multiple)
Acknowledge one or several received messages.
|
Observable<JsonObject> |
RabbitMQClient.basicGetObservable(String queue,
boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.Get
|
Observable<JsonObject> |
RabbitMQClient.basicNackObservable(long deliveryTag,
boolean multiple,
boolean requeue)
Reject one or several received messages.
|
Observable<JsonObject> |
RabbitMQClient.messageCountObservable(String queue)
Returns the number of messages in a queue ready to be delivered.
|
Observable<JsonObject> |
RabbitMQClient.queueDeclareAutoObservable()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Observable<JsonObject> |
RabbitMQClient.queueDeclareObservable(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete)
Declare a queue
|
Observable<JsonObject> |
RabbitMQClient.queueDeleteIfObservable(String queue,
boolean ifUnused,
boolean ifEmpty)
Delete a queue
|
Observable<JsonObject> |
RabbitMQClient.queueDeleteObservable(String queue)
Delete a queue, without regard for whether it is in use or has messages on it
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
JsonObject message,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Observable<Void> |
RabbitMQClient.basicPublishObservable(String exchange,
String routingKey,
JsonObject message)
Publish a message.
|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.basicAck(long deliveryTag,
boolean multiple,
Handler<AsyncResult<JsonObject>> resultHandler)
Acknowledge one or several received messages.
|
void |
RabbitMQClient.basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<JsonObject>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
void |
RabbitMQClient.basicNack(long deliveryTag,
boolean multiple,
boolean requeue,
Handler<AsyncResult<JsonObject>> resultHandler)
Reject one or several received messages.
|
void |
RabbitMQClient.messageCount(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Returns the number of messages in a queue ready to be delivered.
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Handler<AsyncResult<JsonObject>> resultHandler)
Declare a queue
|
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
void |
RabbitMQClient.queueDelete(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue, without regard for whether it is in use or has messages on it
|
void |
RabbitMQClient.queueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue
|
Modifier and Type | Method and Description |
---|---|
Observable<JsonObject> |
RedisClient.hgetallObservable(String key)
Get all the fields and values in a hash
|
Observable<JsonObject> |
RedisClient.infoObservable()
Get information and statistics about the server
|
Observable<JsonObject> |
RedisClient.infoSectionObservable(String section)
Get information and statistics about the server
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisTransaction |
RedisTransaction.hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
Observable<String> |
RedisClient.hmsetObservable(String key,
JsonObject values)
Set multiple hash fields to multiple values
|
Observable<String> |
RedisTransaction.hmsetObservable(String key,
JsonObject values)
Set multiple hash fields to multiple values
|
RedisClient |
RedisClient.mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisTransaction |
RedisTransaction.mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisClient |
RedisClient.msetnx(JsonObject keyvals,
Handler<AsyncResult<Long>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
RedisTransaction |
RedisTransaction.msetnx(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
Observable<Long> |
RedisClient.msetnxObservable(JsonObject keyvals)
Set multiple keys to multiple values, only if none of the keys exist
|
Observable<String> |
RedisTransaction.msetnxObservable(JsonObject keyvals)
Set multiple keys to multiple values, only if none of the keys exist
|
Observable<String> |
RedisClient.msetObservable(JsonObject keyvals)
Set multiple keys to multiple values
|
Observable<String> |
RedisTransaction.msetObservable(JsonObject keyvals)
Set multiple keys to multiple values
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.hgetall(String key,
Handler<AsyncResult<JsonObject>> handler)
Get all the fields and values in a hash
|
RedisClient |
RedisClient.info(Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.infoSection(String section,
Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
Observable<Record> |
ServiceDiscovery.getRecordObservable(JsonObject filter)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
Observable<List<Record>> |
ServiceDiscovery.getRecordsObservable(JsonObject filter)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> future)
Starts the bridge.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Observable<HttpClient> |
HttpEndpoint.getClientObservable(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static <T> Observable<MessageConsumer<T>> |
MessageSource.getConsumerObservable(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Observable<JDBCClient> |
JDBCDataSource.getJDBCClientObservable(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Observable<JDBCClient> |
JDBCDataSource.getJDBCClientObservable(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static <T> void |
EventBusService.getProxy(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> void |
EventBusService.getProxy(ServiceDiscovery discovery,
JsonObject filter,
String proxyClass,
Handler<AsyncResult<T>> resultHandler) |
static <T> Observable<T> |
EventBusService.getProxyObservable(ServiceDiscovery discovery,
JsonObject filter)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> Observable<T> |
EventBusService.getProxyObservable(ServiceDiscovery discovery,
JsonObject filter,
String proxyClass) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ServiceDiscoveryOptions.getBackendConfiguration() |
JsonObject |
Record.getLocation() |
JsonObject |
Record.getMetadata()
Gets the metadata attached to the record.
|
JsonObject |
Record.toJson() |
JsonObject |
ServiceDiscoveryOptions.toJson()
Builds the JSON representation for the current
ServiceDiscoveryOptions . |
Modifier and Type | Method and Description |
---|---|
static void |
RecordConverter.fromJson(JsonObject json,
Record obj) |
static void |
ServiceDiscoveryOptionsConverter.fromJson(JsonObject json,
ServiceDiscoveryOptions obj) |
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
boolean |
Record.match(JsonObject filter)
Checks whether or not the current
Record matches the filter. |
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
ServiceDiscoveryOptions |
ServiceDiscoveryOptions.setBackendConfiguration(JsonObject backendConfiguration)
Sets the configuration passed to the
ServiceDiscoveryBackend . |
Record |
Record.setLocation(JsonObject location)
Sets the json object describing the location of the service.
|
Record |
Record.setMetadata(JsonObject metadata) |
static void |
RecordConverter.toJson(Record obj,
JsonObject json) |
static void |
ServiceDiscoveryOptionsConverter.toJson(ServiceDiscoveryOptions obj,
JsonObject json) |
Constructor and Description |
---|
Record(JsonObject json)
Creates a new
Record from its json representation. |
ServiceDiscoveryOptions(JsonObject json)
Creates a new instance of
ServiceDiscoveryOptions from its JSON representation. |
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 |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> future)
Starts the bridge.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpLocation.toJson() |
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(String, String, int, String, JsonObject) but let you configure whether or not the
service is using https . |
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
EventBusService.createRecord(String name,
String address,
Class itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
Class type,
JsonObject metadata)
Create a record representing a data producer.
|
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
DataSource.createRecord(String name,
String type,
JsonObject location,
JsonObject metadata)
Create a record representing a data source.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static void |
HttpLocationConverter.fromJson(JsonObject json,
HttpLocation obj) |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured
MessageConsumer . |
static void |
DataSource.getDataSourceMetadata(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JsonObject>> resultHandler)
Gets the metadata of a data source service.
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static <T> void |
EventBusService.getProxy(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> void |
EventBusService.getProxy(ServiceDiscovery discovery,
JsonObject filter,
String proxyClass,
Handler<AsyncResult<T>> resultHandler) |
static void |
HttpLocationConverter.toJson(HttpLocation obj,
JsonObject json) |
Modifier and Type | Method and Description |
---|---|
static void |
DataSource.getDataSourceMetadata(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JsonObject>> resultHandler)
Gets the metadata of a data source service.
|
Constructor and Description |
---|
HttpLocation(JsonObject json)
Creates a new
HttpLocation from the given json object |
Modifier and Type | Field and Description |
---|---|
protected MessageConsumer<JsonObject> |
ProxyHandler.consumer |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ServiceException.getDebugInfo()
Get the Debugging information provided to this ServiceException
|
Modifier and Type | Method and Description |
---|---|
abstract MessageConsumer<JsonObject> |
ProxyHandler.registerHandler(String address)
Register the proxy handle on the event bus.
|
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 |
---|---|
static <T> AsyncResult<T> |
ServiceException.fail(int failureCode,
String message,
JsonObject debugInfo)
Create a failed Future containing a ServiceException.
|
Modifier and Type | Method and Description |
---|---|
void |
ProxyHandler.setConsumer(MessageConsumer<JsonObject> consumer) |
static void |
ProxyHelper.unregisterService(MessageConsumer<JsonObject> consumer)
Unregisters a published service.
|
Constructor and Description |
---|
ServiceException(int failureCode,
String message,
JsonObject debugInfo) |
Copyright © 2016. All rights reserved.