From 3415f1dd839c45c10d46dd93e7281ea98e2e3947 Mon Sep 17 00:00:00 2001 From: Ramya Achutha Rao Date: Tue, 23 Jun 2020 19:50:44 -0700 Subject: [PATCH] ReceiveBatchOptions -> ReceiveMessagesOptions --- sdk/servicebus/service-bus/review/service-bus.api.md | 10 +++++----- sdk/servicebus/service-bus/src/index.ts | 2 +- sdk/servicebus/service-bus/src/models.ts | 2 +- sdk/servicebus/service-bus/src/receivers/receiver.ts | 6 +++--- .../service-bus/src/receivers/sessionReceiver.ts | 4 ++-- 5 files changed, 12 insertions(+), 12 deletions(-) diff --git a/sdk/servicebus/service-bus/review/service-bus.api.md b/sdk/servicebus/service-bus/review/service-bus.api.md index af079ca3c3b4..6a3eab6f9561 100644 --- a/sdk/servicebus/service-bus/review/service-bus.api.md +++ b/sdk/servicebus/service-bus/review/service-bus.api.md @@ -175,10 +175,6 @@ export interface QueuesResponse extends Array, Response { export interface QueuesRuntimeInfoResponse extends Array, Response { } -// @public -export interface ReceiveBatchOptions extends OperationOptions, WaitTimeOptions { -} - // @public export interface ReceivedMessage extends ServiceBusMessage { readonly _amqpMessage: AmqpMessage; @@ -207,6 +203,10 @@ export interface ReceivedMessageWithLock extends ReceivedMessage { renewLock(): Promise; } +// @public +export interface ReceiveMessagesOptions extends OperationOptions, WaitTimeOptions { +} + // @public export interface Receiver { close(): Promise; @@ -216,7 +216,7 @@ export interface Receiver { isReceivingMessages(): boolean; peekMessages(options?: PeekMessagesOptions): Promise; receiveDeferredMessages(sequenceNumbers: Long | Long[], options?: OperationOptions): Promise; - receiveMessages(maxMessages: number, options?: ReceiveBatchOptions): Promise; + receiveMessages(maxMessages: number, options?: ReceiveMessagesOptions): Promise; receiveMode: "peekLock" | "receiveAndDelete"; subscribe(handlers: MessageHandlers, options?: SubscribeOptions): void; } diff --git a/sdk/servicebus/service-bus/src/index.ts b/sdk/servicebus/service-bus/src/index.ts index a958a1c8150f..f2d469e79cc7 100644 --- a/sdk/servicebus/service-bus/src/index.ts +++ b/sdk/servicebus/service-bus/src/index.ts @@ -22,7 +22,7 @@ export { MessageHandlerOptions, MessageHandlers, PeekMessagesOptions, - ReceiveBatchOptions, + ReceiveMessagesOptions, SenderOpenOptions, SubscribeOptions, WaitTimeOptions diff --git a/sdk/servicebus/service-bus/src/models.ts b/sdk/servicebus/service-bus/src/models.ts index 0e0e2d2442e4..2b2fbdf238b0 100644 --- a/sdk/servicebus/service-bus/src/models.ts +++ b/sdk/servicebus/service-bus/src/models.ts @@ -56,7 +56,7 @@ export interface CreateBatchOptions extends OperationOptions { /** * Options when receiving a batch of messages from Service Bus. */ -export interface ReceiveBatchOptions extends OperationOptions, WaitTimeOptions {} +export interface ReceiveMessagesOptions extends OperationOptions, WaitTimeOptions {} /** * Options when getting an iterable iterator from Service Bus. diff --git a/sdk/servicebus/service-bus/src/receivers/receiver.ts b/sdk/servicebus/service-bus/src/receivers/receiver.ts index 2ce883559bc1..3a13aa47c805 100644 --- a/sdk/servicebus/service-bus/src/receivers/receiver.ts +++ b/sdk/servicebus/service-bus/src/receivers/receiver.ts @@ -5,7 +5,7 @@ import { PeekMessagesOptions, GetMessageIteratorOptions, MessageHandlers, - ReceiveBatchOptions, + ReceiveMessagesOptions, SubscribeOptions } from "../models"; import { OperationOptions } from "../modelsToBeSharedWithEventHubs"; @@ -51,7 +51,7 @@ export interface Receiver { * @param maxMessages The maximum number of messages to accept. * @param options Options for receiveMessages */ - receiveMessages(maxMessages: number, options?: ReceiveBatchOptions): Promise; + receiveMessages(maxMessages: number, options?: ReceiveMessagesOptions): Promise; /** * Returns a promise that resolves to an array of deferred messages identified by given `sequenceNumbers`. @@ -256,7 +256,7 @@ export class ReceiverImpl { this._throwIfReceiverOrConnectionClosed(); this._throwIfAlreadyReceiving(); diff --git a/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts b/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts index 3e7fd9fd6a26..2437657792a4 100644 --- a/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts +++ b/sdk/servicebus/service-bus/src/receivers/sessionReceiver.ts @@ -4,7 +4,7 @@ import { ClientEntityContext } from "../clientEntityContext"; import { MessageHandlers, - ReceiveBatchOptions, + ReceiveMessagesOptions, ReceivedMessage, SessionMessageHandlerOptions, SubscribeOptions @@ -439,7 +439,7 @@ export class SessionReceiverImpl { this._throwIfReceiverOrConnectionClosed(); this._throwIfAlreadyReceiving();