in src/main/java/com/azure/servicebus/jms/ServiceBusJmsConnectionFactory.java [411:430]
private String getFailoverUri(String hostUri, String amqpPerHostQuery, ServiceBusJmsConnectionFactorySettings settings) {
StringBuilder builder = new StringBuilder("failover:(");
builder.append(hostUri);
String[] reconnectHosts = settings.getReconnectHosts();
if (settings.getReconnectHosts() != null) {
for (String reconnectHost: reconnectHosts) {
builder.append(",");
builder.append("amqps://");
builder.append(reconnectHost);
if (!amqpPerHostQuery.isEmpty()) {
builder.append("?");
builder.append(amqpPerHostQuery);
}
}
}
builder.append(")");
return builder.toString();
}