processMessage

abstract fun <R> processMessage(waitTimeoutMs: Long, handler: (msgEnv: MessageEnvelope) -> R): R?