You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jun 20, 2023. It is now read-only.
In the sample below when the query is executed the client connection settings (eg. maxTotalConnetion, defaultMaxTotalConnectionPerRoute, ...etc.) are not applied to a Async calls.
val factory: JestClientFactory = new JestClientFactory()
factory.setHttpClientConfig(new Builder(uri)
.maxConnectionIdleTime(10, TimeUnit.SECONDS)
.maxTotalConnection(50)
.defaultMaxTotalConnectionPerRoute(30)
.connTimeout(3000)
.readTimeout(2000)
.multiThreaded(true)
.build())
val jectClient = factory.getObject
jestClient.executeAsync(search, handler)
The text was updated successfully, but these errors were encountered:
Not sure how to help on the testing question but meanwhile I'm leaving here a note for a temporary workaround we adopted. Might be useful in case other people are reading this because stumbled on the same problem while it gets a proper fix.
We are just re-setting the HttpAsyncClient downcasting JestClient to JestHttpClient and using JestHttpClient.setAsyncClient(...)
val client = factory.getObject
client match {
case jestHttpClient: JestHttpClient => {
jestHttpClient.setAsyncClient(HttpAsyncClients.custom().setMaxConnPerRoute(...).setMaxConnTotal(...).build())
jestHttpClient
}
In the sample below when the query is executed the client connection settings (eg. maxTotalConnetion, defaultMaxTotalConnectionPerRoute, ...etc.) are not applied to a Async calls.
The text was updated successfully, but these errors were encountered: