vertx / io.vertx.reactivex.servicediscovery.types / MessageSource

MessageSource

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.

Constructors

<init>

MessageSource(delegate: MessageSource)

Properties

__TYPE_ARG

static val __TYPE_ARG: TypeArg<MessageSource>

Functions

createRecord

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 io.vertx.reactivex.servicediscovery.types.MessageSource#createRecord without additional metadata.

open static fun createRecord(name: String, address: String): Record

Same as io.vertx.reactivex.servicediscovery.types.MessageSource#createRecord without additional metadata, and no type for the payload.

equals

open fun equals(other: Any?): Boolean

getConsumer

open static fun <T : Any> getConsumer(discovery: ServiceDiscovery, filter: JsonObject, resultHandler: Handler<AsyncResult<MessageConsumer<T>>>): Unit
open 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.

getDelegate

open fun getDelegate(): MessageSource

hashCode

open fun hashCode(): Int

newInstance

open static fun newInstance(arg: MessageSource): MessageSource

rxGetConsumer

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.

toString

open fun toString(): String