From 82b82a0446633f6af13058f44895ad21a1409453 Mon Sep 17 00:00:00 2001 From: HarshaNalluru Date: Tue, 26 Jan 2021 11:56:47 -0800 Subject: [PATCH] comiple issues and migrate to 7.0.0 --- sdk/servicebus/service-bus/test/stress/package.json | 4 ++-- .../service-bus/test/stress/scenarioBatchReceive.ts | 4 ++-- sdk/servicebus/service-bus/test/stress/stressTestsBase.ts | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/sdk/servicebus/service-bus/test/stress/package.json b/sdk/servicebus/service-bus/test/stress/package.json index d40f523bd01d..71e06c56feea 100644 --- a/sdk/servicebus/service-bus/test/stress/package.json +++ b/sdk/servicebus/service-bus/test/stress/package.json @@ -4,13 +4,13 @@ "description": "", "main": "index.js", "scripts": { - "test": "ts-node scenarioBatchReceive.ts --testDurationInMs=10000 --recieveMode=receiveAndDelete" + "test": "ts-node scenarioBatchReceive.ts --testDurationInMs=10000 --receiveMode=receiveAndDelete" }, "keywords": [], "author": "", "license": "ISC", "dependencies": { - "@azure/service-bus": "^7.0.0-preview.8", + "@azure/service-bus": "^7.0.0", "minimist": "^1.2.5", "uuid": "^8.3.0" }, diff --git a/sdk/servicebus/service-bus/test/stress/scenarioBatchReceive.ts b/sdk/servicebus/service-bus/test/stress/scenarioBatchReceive.ts index 58ed07de0dd2..33a324e659c6 100644 --- a/sdk/servicebus/service-bus/test/stress/scenarioBatchReceive.ts +++ b/sdk/servicebus/service-bus/test/stress/scenarioBatchReceive.ts @@ -1,4 +1,4 @@ -import { ReceiveMode, ServiceBusClient, ServiceBusReceiver } from "@azure/service-bus"; +import { ServiceBusClient, ServiceBusReceiver } from "@azure/service-bus"; import { SBStressTestsBase } from "./stressTestsBase"; import { delay } from "rhea-promise"; import parsedArgs from "minimist"; @@ -9,7 +9,7 @@ dotenv.config(); // Define connection string and related Service Bus entity names here const connectionString = process.env.SERVICEBUS_CONNECTION_STRING || ""; - +type ReceiveMode = "receiveAndDelete" | "peekLock"; interface ScenarioReceiveBatchOptions { testDurationInMs?: number; receiveMode?: ReceiveMode; diff --git a/sdk/servicebus/service-bus/test/stress/stressTestsBase.ts b/sdk/servicebus/service-bus/test/stress/stressTestsBase.ts index 7db914c6c909..812f58afe7f0 100644 --- a/sdk/servicebus/service-bus/test/stress/stressTestsBase.ts +++ b/sdk/servicebus/service-bus/test/stress/stressTestsBase.ts @@ -170,7 +170,7 @@ export class SBStressTestsBase { public async receiveStreaming( receiver: ServiceBusReceiver, duration: number, - options: Pick & { + options: Pick & { manualLockRenewal: boolean; completeMessageAfterDuration: boolean; maxAutoRenewLockDurationInMs: number; @@ -185,7 +185,7 @@ export class SBStressTestsBase { if (options.settleMessageOnReceive) { await this.completeMessage(message, receiver); } else if ( - !options.autoComplete && + !options.autoCompleteMessages && options.maxAutoRenewLockDurationInMs === 0 && options.manualLockRenewal ) {