ServiceBusReceiver interface

الحزمة:

@azure/service-bus

جهاز استقبال لا يتعامل مع جلسات العمل.

الخصائص

entityPath	مسار الكيان الذي تم إنشاء المتلقي له.
identifier	اسم يستخدم لتعريف المتلقي. يمكن استخدام هذا لربط السجلات والاستثناءات. إذا لم يتم تحديده أو إفراغه، إنشاء واحد فريد عشوائي.
isClosed	إرجاع true إذا تم إغلاق المتلقي أو العميل الذي أنشأه.
receiveMode	وضع الاستلام المستخدم لإنشاء المتلقي.

الأساليب

abandonMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	يتم ترك التأمين الذي يحتفظ به المتلقي على الرسالة، مما يجعل الرسالة متاحة مرة أخرى في ناقل خدمة Microsoft Azure لعملية تلقي أخرى.
close()	إغلاق المتلقي. بمجرد إغلاقه، لا يمكن استخدام المتلقي لأي عمليات أخرى. استخدم أسلوب createReceiver() على ServiceBusClient لإنشاء جهاز استقبال جديد.
completeMessage(ServiceBusReceivedMessage)	إزالة الرسالة من ناقل خدمة Microsoft Azure.
deadLetterMessage(ServiceBusReceivedMessage, DeadLetterOptions & {[key: string]: number | boolean | string | Date | null})	نقل الرسالة إلى قائمة الانتظار الفرعية غير المستخدمة. لتلقي رسالة deadletted، قم بإنشاء QueueClient/SubscriptionClient جديد باستخدام مسار قائمة الانتظار الفرعية غير المستخدمة.
deferMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	تأجيل معالجة الرسالة. احفظ sequenceNumber الرسالة، لتلقي الرسالة مرة أخرى في المستقبل باستخدام أسلوب receiveDeferredMessage.
getMessageIterator(GetMessageIteratorOptions)	إرجاع مكرر يمكن استخدامه لتلقي الرسائل من ناقل خدمة Microsoft Azure.
peekMessages(number, PeekMessagesOptions)	ألق نظرة خاطفة على الدفعة التالية من الرسائل النشطة (بما في ذلك الرسائل المؤجلة ولكن غير الميتة) في قائمة الانتظار أو الاشتراك دون تعديلها. الاستدعاء الأول peekMessages() يجلب أول رسالة نشطة. كل استدعاء لاحق يجلب الرسالة التالية. على عكس الرسالة "المستلمة"، تكون الرسالة "خاطفة" هي نسخة للقراءة فقط من الرسالة. لا يمكن Completed/Abandoned/Deferred/Deadlettered.
receiveDeferredMessages(Long | Long[], OperationOptionsBase)	إرجاع وعد يحل إلى صفيف من الرسائل المؤجلة التي تم تحديدها بواسطة sequenceNumbers.
receiveMessages(number, ReceiveMessagesOptions)	إرجاع وعد يحل إلى صفيف من الرسائل المستلمة من ناقل خدمة Microsoft Azure.
renewMessageLock(ServiceBusReceivedMessage)	تجديد التأمين على الرسالة للمدة كما هو محدد أثناء إنشاء قائمة الانتظار/الاشتراك. تحقق من خاصية lockedUntilUtc على الرسالة للوقت الذي تنتهي فيه صلاحية التأمين. إذا لم تتم تسوية الرسالة (باستخدام إما complete()أو defer() أو deadletter()، قبل انتهاء صلاحية تأمينها، فستعود الرسالة مرة أخرى إلى قائمة الانتظار/الاشتراك لعملية الاستلام التالية.
subscribe(MessageHandlers, SubscribeOptions)	دفق الرسائل إلى معالجات الرسائل.

تفاصيل الخاصية

entityPath

مسار الكيان الذي تم إنشاء المتلقي له.

entityPath: string

قيمة الخاصية

string

identifier

اسم يستخدم لتعريف المتلقي. يمكن استخدام هذا لربط السجلات والاستثناءات. إذا لم يتم تحديده أو إفراغه، إنشاء واحد فريد عشوائي.

identifier: string

قيمة الخاصية

string

isClosed

إرجاع true إذا تم إغلاق المتلقي أو العميل الذي أنشأه.

isClosed: boolean

قيمة الخاصية

boolean

receiveMode

وضع الاستلام المستخدم لإنشاء المتلقي.

receiveMode: "peekLock" | "receiveAndDelete"

قيمة الخاصية

"peekLock" | "receiveAndDelete"

تفاصيل الأسلوب

abandonMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})

يتم ترك التأمين الذي يحتفظ به المتلقي على الرسالة، مما يجعل الرسالة متاحة مرة أخرى في ناقل خدمة Microsoft Azure لعملية تلقي أخرى.

function abandonMessage(message: ServiceBusReceivedMessage, propertiesToModify?: {[key: string]: number | boolean | string | Date | null}): Promise<void>

المعلمات

message

ServiceBusReceivedMessage

propertiesToModify

{[key: string]: number | boolean | string | Date | null}

خصائص الرسالة المراد تعديلها أثناء التخلي عن الرسالة.

المرتجعات

Promise<void>

close()

إغلاق المتلقي. بمجرد إغلاقه، لا يمكن استخدام المتلقي لأي عمليات أخرى. استخدم أسلوب createReceiver() على ServiceBusClient لإنشاء جهاز استقبال جديد.

function close(): Promise<void>

المرتجعات

Promise<void>

completeMessage(ServiceBusReceivedMessage)

إزالة الرسالة من ناقل خدمة Microsoft Azure.

function completeMessage(message: ServiceBusReceivedMessage): Promise<void>

المعلمات

message

ServiceBusReceivedMessage

المرتجعات

Promise<void>

deadLetterMessage(ServiceBusReceivedMessage, DeadLetterOptions & {[key: string]: number | boolean | string | Date | null})

نقل الرسالة إلى قائمة الانتظار الفرعية غير المستخدمة. لتلقي رسالة deadletted، قم بإنشاء QueueClient/SubscriptionClient جديد باستخدام مسار قائمة الانتظار الفرعية غير المستخدمة.

function deadLetterMessage(message: ServiceBusReceivedMessage, options?: DeadLetterOptions & {[key: string]: number | boolean | string | Date | null}): Promise<void>

المعلمات

message

ServiceBusReceivedMessage

options

DeadLetterOptions & {[key: string]: number | boolean | string | Date | null}

خيارات DeadLetter التي يمكن توفيرها أثناء رفض الرسالة.

المرتجعات

Promise<void>

deferMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})

تأجيل معالجة الرسالة. احفظ sequenceNumber الرسالة، لتلقي الرسالة مرة أخرى في المستقبل باستخدام أسلوب receiveDeferredMessage.

function deferMessage(message: ServiceBusReceivedMessage, propertiesToModify?: {[key: string]: number | boolean | string | Date | null}): Promise<void>

المعلمات

message

ServiceBusReceivedMessage

propertiesToModify

{[key: string]: number | boolean | string | Date | null}

خصائص الرسالة المراد تعديلها أثناء تأجيل الرسالة

المرتجعات

Promise<void>

getMessageIterator(GetMessageIteratorOptions)

إرجاع مكرر يمكن استخدامه لتلقي الرسائل من ناقل خدمة Microsoft Azure.

function getMessageIterator(options?: GetMessageIteratorOptions): AsyncIterableIterator<ServiceBusReceivedMessage>

المعلمات

options

GetMessageIteratorOptions

مجموعة من الخيارات للتحكم في عملية الاستلام.

• abortSignal: الإشارة التي يجب استخدامها لإجهاض العملية الجارية.

المرتجعات

AsyncIterableIterator<ServiceBusReceivedMessage>

peekMessages(number, PeekMessagesOptions)

ألق نظرة خاطفة على الدفعة التالية من الرسائل النشطة (بما في ذلك الرسائل المؤجلة ولكن غير الميتة) في قائمة الانتظار أو الاشتراك دون تعديلها.

• الاستدعاء الأول peekMessages() يجلب أول رسالة نشطة. كل استدعاء لاحق يجلب الرسالة التالية.
• على عكس الرسالة "المستلمة"، تكون الرسالة "خاطفة" هي نسخة للقراءة فقط من الرسالة. لا يمكن Completed/Abandoned/Deferred/Deadlettered.

function peekMessages(maxMessageCount: number, options?: PeekMessagesOptions): Promise<ServiceBusReceivedMessage[]>

المعلمات

maxMessageCount

number

الحد الأقصى لعدد الرسائل التي يجب النظر إليها خاطفة.

options

PeekMessagesOptions

الخيارات التي تسمح بتحديد الحد الأقصى لعدد الرسائل التي تريد خاطفتها، أو sequenceNumber لبدء النظرة الخاطفة من أو abortSignal لإجهاض العملية.

المرتجعات

Promise<ServiceBusReceivedMessage[]>

receiveDeferredMessages(Long | Long[], OperationOptionsBase)

إرجاع وعد يحل إلى صفيف من الرسائل المؤجلة التي تم تحديدها بواسطة sequenceNumbers.

function receiveDeferredMessages(sequenceNumbers: Long | Long[], options?: OperationOptionsBase): Promise<ServiceBusReceivedMessage[]>

المعلمات

sequenceNumbers

Long | Long[]

رقم التسلسل أو صفيف من أرقام التسلسل للرسائل التي يجب تلقيها.

options

OperationOptionsBase

حقيبة خيارات لتمرير إشارة إحباط أو خيارات التتبع.

المرتجعات

Promise<ServiceBusReceivedMessage[]>

قائمة بالرسائل التي تم تعريفها بواسطة التسلسل المحددNumbers أو قائمة فارغة إذا لم يتم العثور على رسائل.

receiveMessages(number, ReceiveMessagesOptions)

إرجاع وعد يحل إلى صفيف من الرسائل المستلمة من ناقل خدمة Microsoft Azure.

function receiveMessages(maxMessageCount: number, options?: ReceiveMessagesOptions): Promise<ServiceBusReceivedMessage[]>

المعلمات

maxMessageCount

number

الحد الأقصى لعدد الرسائل التي يجب تلقيها.

options

ReceiveMessagesOptions

مجموعة من الخيارات للتحكم في عملية الاستلام.

• maxWaitTimeInMs: الحد الأقصى لوقت انتظار الرسالة الأولى قبل إرجاع صفيف فارغ إذا لم تتوفر أي رسائل.
• abortSignal: الإشارة التي يجب استخدامها لإجهاض العملية الجارية.

المرتجعات

Promise<ServiceBusReceivedMessage[]>

وعد يحل بمجموعة من الرسائل.

renewMessageLock(ServiceBusReceivedMessage)

تجديد التأمين على الرسالة للمدة كما هو محدد أثناء إنشاء قائمة الانتظار/الاشتراك.

• تحقق من خاصية lockedUntilUtc على الرسالة للوقت الذي تنتهي فيه صلاحية التأمين.
• إذا لم تتم تسوية الرسالة (باستخدام إما complete()أو defer() أو deadletter()، قبل انتهاء صلاحية تأمينها، فستعود الرسالة مرة أخرى إلى قائمة الانتظار/الاشتراك لعملية الاستلام التالية.

function renewMessageLock(message: ServiceBusReceivedMessage): Promise<Date>

المعلمات

message

ServiceBusReceivedMessage

المرتجعات

Promise<Date>

تاريخ ووقت انتهاء صلاحية رمز التأمين الجديد بتنسيق UTC.

subscribe(MessageHandlers, SubscribeOptions)

دفق الرسائل إلى معالجات الرسائل.

function subscribe(handlers: MessageHandlers, options?: SubscribeOptions): { close() => Promise<void> }

المعلمات

handlers

MessageHandlers

معالج يتم استدعاؤه للرسائل والأخطاء.

options

SubscribeOptions

خيارات الاشتراك.

المرتجعات

{ close() => Promise<void> }

كائن يمكن إغلاقه، وإرسال أي رسائل متبقية إلى handlers وإيقاف وصول رسائل جديدة.