Skip to content

Commit

Permalink
Use useSystemProperties with Apache connectors
Browse files Browse the repository at this point in the history
Signed-off-by: jansupol <[email protected]>
  • Loading branch information
jansupol authored and senivam committed Feb 13, 2023
1 parent 1c218be commit 55b7aa9
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -260,10 +260,16 @@ class ApacheConnector implements Connector {
}
}

final boolean useSystemProperties =
PropertiesHelper.isProperty(config.getProperties(), ApacheClientProperties.USE_SYSTEM_PROPERTIES);

final SSLContext sslContext = client.getSslContext();
final HttpClientBuilder clientBuilder = HttpClientBuilder.create();

clientBuilder.setConnectionManager(getConnectionManager(client, config, sslContext));
if (useSystemProperties) {
clientBuilder.useSystemProperties();
}
clientBuilder.setConnectionManager(getConnectionManager(client, config, sslContext, useSystemProperties));
clientBuilder.setConnectionManagerShared(
PropertiesHelper.getValue(config.getProperties(), ApacheClientProperties.CONNECTION_MANAGER_SHARED, false, null));
clientBuilder.setSSLContext(sslContext);
Expand Down Expand Up @@ -342,7 +348,8 @@ class ApacheConnector implements Connector {

private HttpClientConnectionManager getConnectionManager(final Client client,
final Configuration config,
final SSLContext sslContext) {
final SSLContext sslContext,
final boolean useSystemProperties) {
final Object cmObject = config.getProperties().get(ApacheClientProperties.CONNECTION_MANAGER);

// Connection manager from configuration.
Expand All @@ -360,9 +367,6 @@ private HttpClientConnectionManager getConnectionManager(final Client client,
}
}

final boolean useSystemProperties =
PropertiesHelper.isProperty(config.getProperties(), ApacheClientProperties.USE_SYSTEM_PROPERTIES);

// Create custom connection manager.
return createConnectionManager(
client,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -258,10 +258,17 @@ class Apache5Connector implements Connector {
}
}

final boolean useSystemProperties =
PropertiesHelper.isProperty(config.getProperties(), Apache5ClientProperties.USE_SYSTEM_PROPERTIES);

final SSLContext sslContext = client.getSslContext();
final HttpClientBuilder clientBuilder = HttpClientBuilder.create();

clientBuilder.setConnectionManager(getConnectionManager(client, config, sslContext));
if (useSystemProperties) {
clientBuilder.useSystemProperties();
}

clientBuilder.setConnectionManager(getConnectionManager(client, config, sslContext, useSystemProperties));
clientBuilder.setConnectionManagerShared(
PropertiesHelper.getValue(
config.getProperties(),
Expand Down Expand Up @@ -348,7 +355,8 @@ class Apache5Connector implements Connector {

private HttpClientConnectionManager getConnectionManager(final Client client,
final Configuration config,
final SSLContext sslContext) {
final SSLContext sslContext,
final boolean useSystemProperties) {
final Object cmObject = config.getProperties().get(Apache5ClientProperties.CONNECTION_MANAGER);

// Connection manager from configuration.
Expand All @@ -366,9 +374,6 @@ private HttpClientConnectionManager getConnectionManager(final Client client,
}
}

final boolean useSystemProperties =
PropertiesHelper.isProperty(config.getProperties(), Apache5ClientProperties.USE_SYSTEM_PROPERTIES);

// Create custom connection manager.
return createConnectionManager(
client,
Expand Down

0 comments on commit 55b7aa9

Please sign in to comment.