awaitRequest
fun awaitRequest(key: ByteString, message: ProtoMessageWrapper, timeoutMs: Long = DEFALT_AWAIT_TIMEOUT, needNum: Boolean = true): ProtoMessageWrapper
Отправить запрос и дождаться ответа в синхронном стиле
Return
Ответ на запрос идентифицированный по ключу
Parameters
key
Ключ сообщения для идентификации ответов
message
Сам запрос
timeoutMs
Время ожидания (мс)
fun awaitRequest(topic: String, key: ByteString, message: ProtoMessageWrapper, timeoutMs: Long = DEFALT_AWAIT_TIMEOUT, needNum: Boolean = true): ProtoMessageWrapper
Отправить запрос и дождаться ответа в синхронном стиле
Return
Ответ на запрос идентифицированный по ключу
Parameters
topic
Топик назначене запроса
key
Ключ сообщения для идентификации ответов
message
Сам запрос
timeoutMs
Время ожидания (мс)
Throws
если запрос с таким ключом уже есть в очереди