Advertisement
gilstr

Untitled

Jun 8th, 2020
1,082
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.06 KB | None | 0 0
  1.     public ClientHttpRequestFactory clientHttpRequestFactory() throws IOReactorException {
  2.         final DefaultConnectingIOReactor ioreactor = new DefaultConnectingIOReactor(IOReactorConfig.custom().
  3.                 setConnectTimeout(3000).
  4.                 setIoThreadCount(4).
  5.                 setSoTimeout(3000).
  6.                 build());
  7.  
  8.         final PoolingNHttpClientConnectionManager connectionManager = new PoolingNHttpClientConnectionManager(ioreactor);
  9.         connectionManager.setDefaultMaxPerRoute(100);
  10.         connectionManager.setMaxTotal(1000);
  11.  
  12.         CloseableHttpAsyncClient httpAsyncClient = HttpAsyncClients.custom()
  13.                 .setConnectionManager(connectionManager)
  14.                 .build();
  15.  
  16.         return new HttpComponentsAsyncClientHttpRequestFactory(httpAsyncClient);
  17.  
  18.     }
  19.  
  20.     @Override
  21.     public void customize(RestTemplate restTemplate) {
  22.         try {
  23.             restTemplate.setRequestFactory(clientHttpRequestFactory());
  24.         } catch (IOReactorException e) {
  25.             e.printStackTrace();
  26.         }
  27.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement