Package | Description |
---|---|
io.vertx.rxjava.servicediscovery | |
io.vertx.rxjava.servicediscovery.types |
Modifier and Type | Method and Description |
---|---|
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery . |
static ServiceDiscovery |
ServiceDiscovery.newInstance(ServiceDiscovery arg) |
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 |
---|---|
static void |
ServiceDiscovery.releaseServiceObject(ServiceDiscovery discovery,
Object svcObject)
Release the service object retrieved using
get methods from the service type interface. |
Modifier and Type | Method and Description |
---|---|
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> void |
EventBusService.getProxy(ServiceDiscovery discovery,
String itf,
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,
String serviceInterface,
String proxyInterface,
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) |
static <T> Observable<T> |
EventBusService.getProxyObservable(ServiceDiscovery discovery,
String itf)
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,
String serviceInterface,
String proxyInterface) |
Copyright © 2016. All rights reserved.