diff --git a/sdk/servicebus/service-bus/src/receivers/receiver.ts b/sdk/servicebus/service-bus/src/receivers/receiver.ts index 890544b19338..cb1c16d010a3 100644 --- a/sdk/servicebus/service-bus/src/receivers/receiver.ts +++ b/sdk/servicebus/service-bus/src/receivers/receiver.ts @@ -323,7 +323,7 @@ export class ReceiverImpl(config); @@ -389,7 +389,8 @@ export class ReceiverImpl(config); } @@ -440,7 +441,8 @@ export class ReceiverImpl(config); } @@ -469,7 +471,8 @@ export class ReceiverImpl(config); } @@ -502,7 +505,8 @@ export class ReceiverImpl(config); } diff --git a/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts b/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts index b72a89873468..eaa8d10661b7 100644 --- a/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts +++ b/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts @@ -285,7 +285,8 @@ export class SessionReceiverImpl(config); } @@ -314,7 +315,8 @@ export class SessionReceiverImpl(config); } @@ -342,7 +344,8 @@ export class SessionReceiverImpl(config); } @@ -385,7 +388,8 @@ export class SessionReceiverImpl(config); } @@ -431,7 +435,8 @@ export class SessionReceiverImpl(config); } @@ -480,7 +485,8 @@ export class SessionReceiverImpl(config); } @@ -532,7 +538,8 @@ export class SessionReceiverImpl(config); } @@ -573,7 +580,8 @@ export class SessionReceiverImpl(config); } diff --git a/sdk/servicebus/service-bus/src/receivers/subscriptionRuleManager.ts b/sdk/servicebus/service-bus/src/receivers/subscriptionRuleManager.ts index 2707f7db3092..e556cd3ae6c8 100644 --- a/sdk/servicebus/service-bus/src/receivers/subscriptionRuleManager.ts +++ b/sdk/servicebus/service-bus/src/receivers/subscriptionRuleManager.ts @@ -102,7 +102,8 @@ export class SubscriptionRuleManagerImpl implements SubscriptionRuleManager { operation: getRulesOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._ruleManagerOptions.retryOptions + retryOptions: this._ruleManagerOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } @@ -125,7 +126,8 @@ export class SubscriptionRuleManagerImpl implements SubscriptionRuleManager { operation: removeRuleOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._ruleManagerOptions.retryOptions + retryOptions: this._ruleManagerOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } @@ -153,7 +155,8 @@ export class SubscriptionRuleManagerImpl implements SubscriptionRuleManager { operation: addRuleOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._ruleManagerOptions.retryOptions + retryOptions: this._ruleManagerOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } diff --git a/sdk/servicebus/service-bus/src/sender.ts b/sdk/servicebus/service-bus/src/sender.ts index c1afeed32701..26e61c1f635a 100644 --- a/sdk/servicebus/service-bus/src/sender.ts +++ b/sdk/servicebus/service-bus/src/sender.ts @@ -273,7 +273,8 @@ export class SenderImpl implements Sender { operation: scheduleMessageOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._senderOptions.retryOptions + retryOptions: this._senderOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } @@ -305,7 +306,8 @@ export class SenderImpl implements Sender { operation: scheduleMessageOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._senderOptions.retryOptions + retryOptions: this._senderOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } @@ -337,7 +339,8 @@ export class SenderImpl implements Sender { operation: cancelSchedulesMessagesOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._senderOptions.retryOptions + retryOptions: this._senderOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); } @@ -372,7 +375,8 @@ export class SenderImpl implements Sender { operation: cancelSchedulesMessagesOperationPromise, connectionId: this._context.namespace.connectionId, operationType: RetryOperationType.management, - retryOptions: this._senderOptions.retryOptions + retryOptions: this._senderOptions.retryOptions, + abortSignal: options?.abortSignal }; return retry(config); }