Skip to content

Commit c1569a9

Browse files
committed
fix maximum connections issue
1 parent 7d38cbf commit c1569a9

File tree

2 files changed

+11
-3
lines changed
  • kotlin-telegram-framework/src/main/kotlin/io/cutebot/telegram/client
  • samples/stateful-bot/src/main/kotlin/io/cutebot/telegram/samples/statefulbot

2 files changed

+11
-3
lines changed

kotlin-telegram-framework/src/main/kotlin/io/cutebot/telegram/client/TelegramApi.kt

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,14 +32,24 @@ import org.apache.http.entity.mime.MultipartEntity
3232
import org.apache.http.entity.mime.content.FileBody
3333
import org.apache.http.entity.mime.content.StringBody
3434
import org.apache.http.impl.client.HttpClientBuilder
35+
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager
3536
import org.slf4j.LoggerFactory
3637

3738

38-
class TelegramApi {
39+
class TelegramApi(
40+
maxConnections: Int = 5000
41+
) {
42+
43+
private val connectionManager = PoolingHttpClientConnectionManager()
44+
init {
45+
connectionManager.maxTotal = maxConnections
46+
connectionManager.defaultMaxPerRoute = maxConnections
47+
}
3948

4049
private val objectMapper = jacksonObjectMapper()
4150
private val httpClient = HttpClientBuilder
4251
.create()
52+
.setConnectionManager(connectionManager)
4353
.build()
4454

4555
fun getMe(token: String): TgUser {

samples/stateful-bot/src/main/kotlin/io/cutebot/telegram/samples/statefulbot/StatefulBotExample.kt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,7 @@ class StatefulBotExample(
77
private val token: String,
88
currentBlock: BotBlock
99
): StatefulBot(currentBlock) {
10-
1110
override fun getToken(): String {
1211
return token
1312
}
14-
1513
}

0 commit comments

Comments
 (0)