object MessageSource
suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: JsonObject): MessageConsumer<T>suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: Function<Record, Boolean>): 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. |