in src/main/java/com/azure/servicebus/jms/ServiceBusJmsConnectionFactory.java [378:407]
private String getServiceBusRemoteConnectionUri()
{
String hostUri = "amqps://" + this.host;
String amqpPerHostQuery = settings.getPerHostAmqpProviderQuery();
if (!amqpPerHostQuery.isEmpty()) {
hostUri += "?" + amqpPerHostQuery;
}
String jmsProviderQuery = settings.getGlobalJMSProviderQuery();
String remoteConnectionUri;
if (this.settings.shouldReconnect()) {
String failoverUri = this.getFailoverUri(hostUri, amqpPerHostQuery, this.settings);
// Append failover Provider options if any
String failoverOptionsQuery = settings.getGlobalFailoverProviderQuery();
remoteConnectionUri = failoverUri + (!failoverOptionsQuery.isEmpty() ? "?" + failoverOptionsQuery : "");
//Append jmsProvider options if any
if (!jmsProviderQuery.isEmpty()) {
remoteConnectionUri += (!failoverOptionsQuery.isEmpty() ? "&" : "?") + jmsProviderQuery;
}
}
else {
remoteConnectionUri = hostUri + (!jmsProviderQuery.isEmpty() ? (amqpPerHostQuery.isEmpty() ? "?" : "&") + jmsProviderQuery : "");
}
return remoteConnectionUri;
}