ServiceBusReceiver interface

Paket:

@azure/service-bus

Oturumları işlemeyen bir alıcı.

Özellikler

entityPath	Alıcının oluşturulduğu varlığın yolu.
identifier	Alıcıyı tanımlamak için kullanılan ad. Bu, günlükleri ve özel durumları ilişkilendirmek için kullanılabilir. Belirtilmezse veya boşsa rastgele benzersiz bir tane oluşturulur.
isClosed	Alıcı veya onu oluşturan istemci kapatılmışsa döndürür true .
receiveMode	Alıcıyı oluşturmak için kullanılan alma modu.

Yöntemler

abandonMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	Alıcı tarafından iletide tutulan kilit serbest bırakılarak iletinin Service Bus'ta başka bir alma işlemi için yeniden kullanılabilir duruma getirilmesi sağlanır.
close()	Alıcıyı kapatır. Kapatıldıktan sonra alıcı başka işlemler için kullanılamaz. createReceiver() Yeni bir Alıcı oluşturmak için ServiceBusClient'da yöntemini kullanın.
completeMessage(ServiceBusReceivedMessage)	İletiyi Service Bus'tan kaldırır.
deadLetterMessage(ServiceBusReceivedMessage, DeadLetterOptions & {[key: string]: number | boolean | string | Date | null})	İletiyi geçersiz hale getirmek için alt kuyruğa taşır. Geçersiz bir ileti almak için, geçersiz hale gelen alt kuyruğun yolunu kullanarak yeni bir QueueClient/SubscriptionClient oluşturun.
deferMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	İletinin işlenmesini geçersiz hale getirerek. sequenceNumber gelecekte yöntemini kullanarak iletiyi yeniden almak için iletisini kaydedinreceiveDeferredMessage.
getMessageIterator(GetMessageIteratorOptions)	Service Bus'tan ileti almak için kullanılabilecek bir yineleyici döndürür.
peekMessages(number, PeekMessagesOptions)	Değiştirmeden kuyrukta veya abonelikte bir sonraki etkin ileti grubuna (ertelenmiş ancak geçersiz olmayan iletiler dahil) göz atın. İlk çağrı peekMessages() ilk etkin iletiyi getirir. Sonraki her çağrı, sonraki iletiyi getirir. "Alındı" iletisinden farklı olarak, "göz atılan" ileti iletinin salt okunur bir sürümüdür. olamaz Completed/Abandoned/Deferred/Deadlettered.
receiveDeferredMessages(Long | Long[], OperationOptionsBase)	Verilen sequenceNumberstarafından tanımlanan ertelenen iletiler dizisine çözümlenen bir söz döndürür.
receiveMessages(number, ReceiveMessagesOptions)	Service Bus'tan alınan bir dizi iletiye çözümleyen bir söz döndürür.
renewMessageLock(ServiceBusReceivedMessage)	Kuyruk/Abonelik oluşturma sırasında belirtilen süre boyunca iletideki kilidi yeniler. Kilidin lockedUntilUtc süresi dolduğunda iletideki özelliğini denetleyin. İleti kapatılmazsa (kilidin süresi dolmadan önce , defer() veya deadletter()kullanarakcomplete()), ileti sonraki alma işlemi için Kuyruk/Abonelik'e geri döner.
subscribe(MessageHandlers, SubscribeOptions)	İletileri ileti işleyicilerine akışla aktarın.

Özellik Ayrıntıları

entityPath

Alıcının oluşturulduğu varlığın yolu.

entityPath: string

Özellik Değeri

string

identifier

Alıcıyı tanımlamak için kullanılan ad. Bu, günlükleri ve özel durumları ilişkilendirmek için kullanılabilir. Belirtilmezse veya boşsa rastgele benzersiz bir tane oluşturulur.

identifier: string

Özellik Değeri

string

isClosed

Alıcı veya onu oluşturan istemci kapatılmışsa döndürür true .

isClosed: boolean

Özellik Değeri

boolean

receiveMode

Alıcıyı oluşturmak için kullanılan alma modu.

receiveMode: "peekLock" | "receiveAndDelete"

Özellik Değeri

"peekLock" | "receiveAndDelete"

Yöntem Ayrıntıları

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

Alıcı tarafından iletide tutulan kilit serbest bırakılarak iletinin Service Bus'ta başka bir alma işlemi için yeniden kullanılabilir duruma getirilmesi sağlanır.

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

Parametreler

message

ServiceBusReceivedMessage

propertiesToModify

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

İletiyi bırakırken değiştirileceği iletinin özellikleri.

Döndürülenler

Promise<void>

close()

Alıcıyı kapatır. Kapatıldıktan sonra alıcı başka işlemler için kullanılamaz. createReceiver() Yeni bir Alıcı oluşturmak için ServiceBusClient'da yöntemini kullanın.

function close(): Promise<void>

Döndürülenler

Promise<void>

completeMessage(ServiceBusReceivedMessage)

İletiyi Service Bus'tan kaldırır.

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

Parametreler

message

ServiceBusReceivedMessage

Döndürülenler

Promise<void>

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

İletiyi geçersiz hale getirmek için alt kuyruğa taşır. Geçersiz bir ileti almak için, geçersiz hale gelen alt kuyruğun yolunu kullanarak yeni bir QueueClient/SubscriptionClient oluşturun.

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

Parametreler

message

ServiceBusReceivedMessage

options

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

İleti reddederken sağlanabilir DeadLetter seçenekleri.

Döndürülenler

Promise<void>

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

İletinin işlenmesini geçersiz hale getirerek. sequenceNumber gelecekte yöntemini kullanarak iletiyi yeniden almak için iletisini kaydedinreceiveDeferredMessage.

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

Parametreler

message

ServiceBusReceivedMessage

propertiesToModify

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

İleti ertelenirken değiştirileceği iletinin özellikleri

Döndürülenler

Promise<void>

getMessageIterator(GetMessageIteratorOptions)

Service Bus'tan ileti almak için kullanılabilecek bir yineleyici döndürür.

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

Parametreler

options

GetMessageIteratorOptions

Alma işlemini denetlemek için bir dizi seçenek.

• abortSignal: Devam eden işlemi durdurmak için kullanılacak sinyal.

Döndürülenler

AsyncIterableIterator<ServiceBusReceivedMessage>

peekMessages(number, PeekMessagesOptions)

Değiştirmeden kuyrukta veya abonelikte bir sonraki etkin ileti grubuna (ertelenmiş ancak geçersiz olmayan iletiler dahil) göz atın.

• İlk çağrı peekMessages() ilk etkin iletiyi getirir. Sonraki her çağrı, sonraki iletiyi getirir.
• "Alındı" iletisinden farklı olarak, "göz atılan" ileti iletinin salt okunur bir sürümüdür. olamaz Completed/Abandoned/Deferred/Deadlettered.

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

Parametreler

maxMessageCount

number

Göz atacak ileti sayısı üst sınırı.

options

PeekMessagesOptions

Göz atılacak en fazla ileti sayısını, göz atmaya başlanması gereken sequenceNumber değerini veya işlemi durdurmak için abortSignal değerini belirtmeye olanak sağlayan seçenekler.

Döndürülenler

Promise<ServiceBusReceivedMessage[]>

receiveDeferredMessages(Long | Long[], OperationOptionsBase)

Verilen sequenceNumberstarafından tanımlanan ertelenen iletiler dizisine çözümlenen bir söz döndürür.

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

Parametreler

sequenceNumbers

Long | Long[]

Alınması gereken iletiler için sıra numarası veya dizi numaraları dizisi.

options

OperationOptionsBase

Durdurma sinyali veya izleme seçeneklerini geçirmek için seçenekler paketi.

Döndürülenler

Promise<ServiceBusReceivedMessage[]>

Verilen sequenceNumbers tarafından tanımlanan iletilerin listesi veya ileti bulunamazsa boş bir liste.

receiveMessages(number, ReceiveMessagesOptions)

Service Bus'tan alınan bir dizi iletiye çözümleyen bir söz döndürür.

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

Parametreler

maxMessageCount

number

Alınacak en fazla ileti sayısı.

options

ReceiveMessagesOptions

Alma işlemini denetlemek için bir dizi seçenek.

• maxWaitTimeInMs: Kullanılabilir ileti yoksa boş bir dizi döndürmeden önce ilk iletiyi bekleme süresi.
• abortSignal: Devam eden işlemi durdurmak için kullanılacak sinyal.

Döndürülenler

Promise<ServiceBusReceivedMessage[]>

Bir dizi iletiyle çözülen bir söz.

renewMessageLock(ServiceBusReceivedMessage)

Kuyruk/Abonelik oluşturma sırasında belirtilen süre boyunca iletideki kilidi yeniler.

• Kilidin lockedUntilUtc süresi dolduğunda iletideki özelliğini denetleyin.
• İleti kapatılmazsa (kilidin süresi dolmadan önce , defer() veya deadletter()kullanarakcomplete()), ileti sonraki alma işlemi için Kuyruk/Abonelik'e geri döner.

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

Parametreler

message

ServiceBusReceivedMessage

Döndürülenler

Promise<Date>

Utc biçiminde yeni kilit belirteci süre sonu tarihi ve saati.

subscribe(MessageHandlers, SubscribeOptions)

İletileri ileti işleyicilerine akışla aktarın.

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

Parametreler

handlers

MessageHandlers

İletiler ve hatalar için çağrılan işleyici.

options

SubscribeOptions

Abone olma seçenekleri.

Döndürülenler

{ close() => Promise<void> }

Kapatılabilen, kalan iletileri gönderebilen ve yeni iletilerin handlers gelişini durduran bir nesne.