Java sample to reset connections every 30 seconds

sample.java

object PoolingHttpClientFactory {
    private val poolingConnectionManager = PoolingHttpClientConnectionManager().apply {
        maxTotal = 40
        defaultMaxPerRoute = 40
    }



// called every 30 seconds from a scheduled task
    fun cleanupConnections() {
        poolingConnectionManager.closeExpiredConnections()
        poolingConnectionManager.closeIdleConnections(2, MINUTES)
    }

    fun create(): HttpClient {
        val requestConfig = RequestConfig.custom()
            .setConnectTimeout(SECONDS.toMillis(15).toInt())
            .setConnectionRequestTimeout(SECONDS.toMillis(15).toInt())
            .setSocketTimeout(SECONDS.toMillis(60).toInt())
            .build()
        return HttpClients.custom()
            .setDefaultRequestConfig(requestConfig)
            .setConnectionManager(poolingConnectionManager)
            .build()
    }
}


@Configuration
class ClientHttpRequestFactoryConfiguration {
    private val logger = LoggerFactory.getLogger(this::class.java)

    @Bean
    fun clientHttpRequestFactory() = HttpComponentsClientHttpRequestFactory(PoolingHttpClientFactory.create())

    @Scheduled(initialDelay = 30_000, fixedDelay = 30_000)
    fun cleanupConnections() {
        logger.info("cleanup connections")
        PoolingHttpClientFactory.cleanupConnections()
    }
}