feat: reuse connections in http client + increase max sockets (#1220)

* feat: reuse connections in http client + increase max sockets * fix: bump up max free sockets * fix: only keep keep alive to true, rest use dafaults --------- Co-authored-by: Samika Kashyap <[email protected]>
ceramicnetwork · May 30, 2024 · c2121a0 · c2121a0
1 parent 9820eb6
commit c2121a0
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/services/queue/sqs-queue-service.ts b/src/services/queue/sqs-queue-service.ts
@@ -21,6 +21,8 @@ import { AnchorBatchQMessage, RequestQMessage } from '../../models/queue-message
 import { Codec, decode } from 'codeco'
 import { AbortOptions } from '@ceramicnetwork/common'
 import { logger } from '../../logger/index.js'
+import * as http from 'http'
+import { NodeHttpHandler } from '@smithy/node-http-handler'
 
 const DEFAULT_MAX_TIME_TO_HOLD_MESSAGES_S = 21600
 const DEFAULT_WAIT_TIME_FOR_MESSAGE_S = 10
@@ -123,6 +125,11 @@ export class SqsQueueService<TValue extends QueueMessageData>
       region: config.queue.awsRegion,
       endpoint: this.sqsQueueUrl,
       logger: awsLogger,
+      requestHandler: new NodeHttpHandler({
+        httpAgent: new http.Agent({
+          keepAlive: true,
+        }),
+      }),
     })
     this.maxTimeToHoldMessageSec =
       config.queue.maxTimeToHoldMessageSec || DEFAULT_MAX_TIME_TO_HOLD_MESSAGES_S