open class MessageSource
Service type for data producer. Providers are publishing data to a specific event bus address. NOTE: This class has been automatically generated from the io.vertx.servicediscovery.types.MessageSource non RX-ified interface using Vert.x codegen.
MessageSource(delegate: MessageSource) |
static val __TYPE_ARG: TypeArg<MessageSource> |
open static fun createRecord(name: String, address: String, type: String, metadata: JsonObject): Record
Create a record representing a data producer. open static fun createRecord(name: String, address: String, type: String): Record
Same as open static fun createRecord(name: String, address: String): Record
Same as |
|
open fun equals(other: Any?): Boolean |
|
open static fun <T : Any> getConsumer(discovery: ServiceDiscovery, filter: JsonObject, resultHandler: Handler<AsyncResult<MessageConsumer<T>>>): Unitopen static fun <T : Any> getConsumer(discovery: ServiceDiscovery, filter: Function<Record, Boolean>, resultHandler: Handler<AsyncResult<MessageConsumer<T>>>): Unit
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. |
|
open fun getDelegate(): MessageSource |
|
open fun hashCode(): Int |
|
open static fun newInstance(arg: MessageSource): MessageSource |
|
open static fun <T : Any> rxGetConsumer(discovery: ServiceDiscovery, filter: JsonObject): Single<MessageConsumer<T>>open static fun <T : Any> rxGetConsumer(discovery: ServiceDiscovery, filter: Function<Record, Boolean>): Single<MessageConsumer<T>>
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails. |
|
open fun toString(): String |