in core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala [115:125]
def setEndpoint(namespaceName: String, domainName: String): ConnectionStringBuilder = {
try {
this.endpoint = new URI(s"$DefaultProtocol$namespaceName.$domainName")
} catch {
case exception: URISyntaxException =>
throw new IllegalConnectionStringFormatException(
String.format(Locale.US, "Invalid namespace name: %s", namespaceName),
exception)
}
this
}