@Override
   public Connection getConnection(Properties properties, String connectionString, SSLContextSettings sslContextSettings) {
      try {
         RestClientConfigurationBuilder builder = new RestClientConfigurationBuilder().withProperties(properties);
         if (connectionString == null || connectionString.isEmpty() || "-".equals(connectionString)) {
            builder.addServer().host("localhost").port(11222);
         } else {
            Matcher matcher = HOST_PORT.matcher(connectionString);
            if (matcher.matches()) {
               String host = matcher.group(1);
               String port = matcher.group(2);
               builder.addServer().host(host).port(port != null ? Integer.parseInt(port) : 11222);
            } else {
               URL url = new URL(connectionString);
               if (!url.getProtocol().equals("http") && !url.getProtocol().equals("https")) {
                  throw new IllegalArgumentException();
               }

               int port = url.getPort();
               builder.addServer().host(url.getHost()).port(port > 0 ? port : url.getDefaultPort());
               String userInfo = url.getUserInfo();
               if (userInfo != null) {
                  String[] split = userInfo.split(":");
                  builder.security().authentication().username(URLDecoder.decode(split[0], StandardCharsets.UTF_8));
                  if (split.length == 2) {
                     builder.security().authentication().password(URLDecoder.decode(split[1], StandardCharsets.UTF_8));
                  }
               }
               if (url.getProtocol().equals("https")) {
                  SslConfigurationBuilder ssl = builder.security().ssl().enable();
                  if (sslContextSettings != null) {
                     ssl.sslContext(sslContextSettings.getSslContext())
                           .trustManagers(sslContextSettings.getTrustManagers())
                           .hostnameVerifier(sslContextSettings.getHostnameVerifier());
                  }
               }
            }
         }
         builder.header("User-Agent", Version.getBrandName() + " CLI " + Version.getBrandVersion());
         return new RestConnection(builder);
      } catch (Throwable e) {
         return null;
      }
   }
@Test
   public void testUrlWithCredentials() {
      RestConnector connector = new RestConnector();
      RestConnection connection = (RestConnection) connector.getConnection(new Properties(), "http://user:password@localhost:11222", null);
      RestClientConfigurationBuilder builder = connection.getBuilder();
      RestClientConfiguration configuration = builder.build();
      assertEquals(11222, configuration.servers().get(0).port());
      assertEquals("localhost", configuration.servers().get(0).host());
      assertTrue(configuration.security().authentication().enabled());
      assertEquals("user", configuration.security().authentication().username());
      assertArrayEquals("password".toCharArray(), configuration.security().authentication().password());
   }