Skip to content

Commit

Permalink
Update packages/server/src/websocket/websocket.service.ts
Browse files Browse the repository at this point in the history
Co-authored-by: Ariel Gentile <[email protected]>
  • Loading branch information
gabrielmatau79 and genaris authored Nov 8, 2024
1 parent 7c6493e commit 4fdee2e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion packages/server/src/websocket/websocket.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -727,7 +727,7 @@ export class WebsocketService {
* @param {TakeFromQueueDto} dto - Data transfer object containing query parameters.
* @returns {Promise<QueuedMessage[]>} - A promise that resolves to an array of queued messages.
*/
private async takeMessagesWithSize(dto: TakeFromQueueDto): Promise<QueuedMessage[]> {
private async takeMessagesWithByteCountLimit(dto: TakeFromQueueDto): Promise<QueuedMessage[]> {
const { connectionId, recipientDid, limitSize } = dto
const maxMessageSizeBytes = limitSize * 1024 * 1024
let currentSize = 0
Expand Down

0 comments on commit 4fdee2e

Please sign in to comment.