Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public ClientHttpRequestFactory clientHttpRequestFactory() throws IOReactorException {
- final DefaultConnectingIOReactor ioreactor = new DefaultConnectingIOReactor(IOReactorConfig.custom().
- setConnectTimeout(3000).
- setIoThreadCount(4).
- setSoTimeout(3000).
- build());
- final PoolingNHttpClientConnectionManager connectionManager = new PoolingNHttpClientConnectionManager(ioreactor);
- connectionManager.setDefaultMaxPerRoute(100);
- connectionManager.setMaxTotal(1000);
- CloseableHttpAsyncClient httpAsyncClient = HttpAsyncClients.custom()
- .setConnectionManager(connectionManager)
- .build();
- return new HttpComponentsAsyncClientHttpRequestFactory(httpAsyncClient);
- }
- @Override
- public void customize(RestTemplate restTemplate) {
- try {
- restTemplate.setRequestFactory(clientHttpRequestFactory());
- } catch (IOReactorException e) {
- e.printStackTrace();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement