dhaval201279

public PoolingHttpClientConnectionManager poolingConnectionManager() {
  PoolingHttpClientConnectionManager poolingConnectionManager =
    new PoolingHttpClientConnectionManager(getConnectionSocketFactoryRegistry());
  poolingConnectionManager.setMaxTotal(MAX_CONNECTIONS);
  poolingConnectionManager.setDefaultMaxPerRoute(MAX_PER_ROUTE_CONNECTION);
  poolingConnectionManager.setValidateAfterInactivity(VALIDATE_AFTER_INACTIVITY_IN_MILLIS);
  return poolingConnectionManager;
}

dhaval201279

private ConnectionKeepAliveStrategy connectionKeepAliveStrategy() {
  return new DefaultConnectionKeepAliveStrategy() {
    @Override
    public long getKeepAliveDuration(final HttpResponse response, final HttpContext context) {
      long keepAliveDuration = super.getKeepAliveDuration(response, context);
      if (keepAliveDuration < 0) {
        keepAliveDuration = DEFAULT_KEEP_ALIVE_TIME_MILLIS;
      } else if (keepAliveDuration > MAX_KEEP_ALIVE_TIME_MILLIS) {
        keepAliveDuration = MAX_KEEP_ALIVE_TIME_MILLIS;
      }

dhaval201279

public Runnable idleAndExpiredConnectionProcessor(final PoolingHttpClientConnectionManager connectionManager) {
  return new Runnable() {
    @Override
    @Scheduled(fixedDelay = 20000)
    public void run() {
      try {
        if (connectionManager != null) {
            connectionManager.closeExpiredConnections();
            connectionManager.closeIdleConnections(IDLE_CONNECTION_WAIT_TIME_SECS, TimeUnit.SECONDS);
        }

dhaval201279

@Retryable(value = {RemoteServiceUnavailableException.class}, maxAttempts = 8,
    backoff = @Backoff(delay = 1000, multiplier = 2), label = "generate-alias-retry-label")
String generateAlias(String cardNo);

@Recover
String fallbackForGenerateAlias(Throwable th, String cardNo);

dhaval201279

public Runnable connectionPoolMetricsLogger(final PoolingHttpClientConnectionManager connectionManager) {
  return new Runnable() {
    @Override
    @Scheduled(fixedDelay = 30000)
    public void run() {
      final StringBuilder buffer = new StringBuilder();
      try {
        if (connectionManager != null) {
          final PoolStats totalPoolStats = connectionManager.getTotalStats();
          log.info(" ** HTTP Client Connection Pool Stats : Available = {}, Leased = {}, Pending = {}, Max = {} **",