From 1f5e04e296559000eb866b6f9a2e7fffa87a22f6 Mon Sep 17 00:00:00 2001 From: Jeremy Meng Date: Wed, 19 Jan 2022 01:35:00 +0000 Subject: [PATCH] [servicebus] set receiver max listener limit to 1000 We have done similar for the sender. --- sdk/servicebus/service-bus/src/core/messageReceiver.ts | 6 ++++-- sdk/servicebus/service-bus/src/session/messageSession.ts | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/sdk/servicebus/service-bus/src/core/messageReceiver.ts b/sdk/servicebus/service-bus/src/core/messageReceiver.ts index c48e761264a3..05a541670d30 100644 --- a/sdk/servicebus/service-bus/src/core/messageReceiver.ts +++ b/sdk/servicebus/service-bus/src/core/messageReceiver.ts @@ -204,11 +204,13 @@ export abstract class MessageReceiver extends LinkEntity { } } - protected createRheaLink( + protected async createRheaLink( options: ReceiverOptions, _abortSignal?: AbortSignalLike ): Promise { - return this._context.connection.createReceiver(options); + const receiver = await this._context.connection.createReceiver(options); + receiver.setMaxListeners(1000); + return receiver; } /** diff --git a/sdk/servicebus/service-bus/src/session/messageSession.ts b/sdk/servicebus/service-bus/src/session/messageSession.ts index 25556ba745af..411f7669c4c2 100644 --- a/sdk/servicebus/service-bus/src/session/messageSession.ts +++ b/sdk/servicebus/service-bus/src/session/messageSession.ts @@ -248,11 +248,13 @@ export class MessageSession extends LinkEntity { } } - protected createRheaLink( + protected async createRheaLink( options: ReceiverOptions, _abortSignal?: AbortSignalLike ): Promise { - return this._context.connection.createReceiver(options); + const receiver = await this._context.connection.createReceiver(options); + receiver.setMaxListeners(1000); + return receiver; } /**