ServiceBusReceiver interface

Paket:

@azure/service-bus

Ein Empfänger, der keine Sitzungen behandelt.

Eigenschaften

entityPath	Pfad der Entität, für die der Empfänger erstellt wurde.
identifier	Ein Name, der zum Identifizieren des Empfängers verwendet wird. Dies kann verwendet werden, um Protokolle und Ausnahmen zu korrelieren. Wenn sie nicht angegeben oder leer ist, wird ein zufällig eindeutiger Wert generiert.
isClosed	Gibt true zurück, wenn der Empfänger oder der Client, der ihn erstellt hat, geschlossen wurde.
receiveMode	Der Empfangsmodus, der zum Erstellen des Empfängers verwendet wird.

Methoden

abandonMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	Die Sperre, die vom Empfänger an der Nachricht gehalten wird, wird losgelassen, sodass die Nachricht wieder in Service Bus für einen anderen Empfangsvorgang verfügbar ist.
close()	Schließt den Empfänger. Nach dem Schließen kann der Empfänger nicht mehr für weitere Vorgänge verwendet werden. Verwenden Sie die createReceiver()-Methode für serviceBusClient, um einen neuen Empfänger zu erstellen.
completeMessage(ServiceBusReceivedMessage)	Entfernt die Nachricht aus service bus.
deadLetterMessage(ServiceBusReceivedMessage, DeadLetterOptions & {[key: string]: number | boolean | string | Date | null})	Verschiebt die Nachricht in die Unterwarteschlange des Deadletters. Um eine Sacklettnachricht zu erhalten, erstellen Sie einen neuen QueueClient/SubscriptionClient mit dem Pfad für die Deadletter-Unterwarteschlange.
deferMessage(ServiceBusReceivedMessage, {[key: string]: number | boolean | string | Date | null})	Verzögert die Verarbeitung der Nachricht. Speichern Sie die sequenceNumber der Nachricht, um sie in Zukunft mit der receiveDeferredMessage-Methode erneut zu empfangen.
getMessageIterator(GetMessageIteratorOptions)	Gibt einen Iterator zurück, der zum Empfangen von Nachrichten von Service Bus verwendet werden kann.
peekMessages(number, PeekMessagesOptions)	Werfen Sie einen Blick auf den nächsten Batch aktiver Nachrichten (einschließlich verzögerter, aber nicht inaktiver Nachrichten) in der Warteschlange oder im Abonnement, ohne sie zu ändern. Der erste Aufruf von peekMessages() ruft die erste aktive Nachricht ab. Jeder nachfolgende Aufruf ruft die nachfolgende Nachricht ab. Im Gegensatz zu einer "empfangenen" Nachricht ist die "Vorschau"-Nachricht eine schreibgeschützte Version der Nachricht. Es kann nicht Completed/Abandoned/Deferred/Deadletteredwerden.
receiveDeferredMessages(Long | Long[], OperationOptionsBase)	Gibt eine Zusage zurück, die in ein Array verzögerter Nachrichten aufgelöst wird, die durch die angegebene sequenceNumbersidentifiziert werden.
receiveMessages(number, ReceiveMessagesOptions)	Gibt eine Zusage zurück, die in ein Array von Nachrichten aufgelöst wird, die von Service Bus empfangen wurden.
renewMessageLock(ServiceBusReceivedMessage)	Erneuert die Sperre für die Nachricht für die Dauer, wie während der Erstellung der Warteschlange/des Abonnements angegeben. Überprüfen Sie die lockedUntilUtc Eigenschaft für die Nachricht, wann die Sperre abläuft. Wenn eine Nachricht nicht abgeschlossen ist (entweder mit complete(), defer() oder deadletter(), bevor die Sperre abläuft, landet die Nachricht wieder in der Warteschlange/im Abonnement für den nächsten Empfangsvorgang.
subscribe(MessageHandlers, SubscribeOptions)	Streamt Nachrichten an Nachrichtenhandler.

Details zur Eigenschaft

entityPath

Pfad der Entität, für die der Empfänger erstellt wurde.

entityPath: string

Eigenschaftswert

string

identifier

Ein Name, der zum Identifizieren des Empfängers verwendet wird. Dies kann verwendet werden, um Protokolle und Ausnahmen zu korrelieren. Wenn sie nicht angegeben oder leer ist, wird ein zufällig eindeutiger Wert generiert.

identifier: string

Eigenschaftswert

string

isClosed

Gibt true zurück, wenn der Empfänger oder der Client, der ihn erstellt hat, geschlossen wurde.

isClosed: boolean

Eigenschaftswert

boolean

receiveMode

Der Empfangsmodus, der zum Erstellen des Empfängers verwendet wird.

receiveMode: "peekLock" | "receiveAndDelete"

Eigenschaftswert

"peekLock" | "receiveAndDelete"

Details zur Methode

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

Die Sperre, die vom Empfänger an der Nachricht gehalten wird, wird losgelassen, sodass die Nachricht wieder in Service Bus für einen anderen Empfangsvorgang verfügbar ist.

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

Parameter

message

ServiceBusReceivedMessage

propertiesToModify

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

Die Eigenschaften der Nachricht, die beim Verlassen der Nachricht geändert werden sollen.

Gibt zurück

Promise<void>

close()

Schließt den Empfänger. Nach dem Schließen kann der Empfänger nicht mehr für weitere Vorgänge verwendet werden. Verwenden Sie die createReceiver()-Methode für serviceBusClient, um einen neuen Empfänger zu erstellen.

function close(): Promise<void>

Gibt zurück

Promise<void>

completeMessage(ServiceBusReceivedMessage)

Entfernt die Nachricht aus service bus.

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

Parameter

message

ServiceBusReceivedMessage

Gibt zurück

Promise<void>

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

Verschiebt die Nachricht in die Unterwarteschlange des Deadletters. Um eine Sacklettnachricht zu erhalten, erstellen Sie einen neuen QueueClient/SubscriptionClient mit dem Pfad für die Deadletter-Unterwarteschlange.

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

Parameter

message

ServiceBusReceivedMessage

options

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

Die DeadLetter-Optionen, die beim Ablehnen der Nachricht bereitgestellt werden können.

Gibt zurück

Promise<void>

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

Verzögert die Verarbeitung der Nachricht. Speichern Sie die sequenceNumber der Nachricht, um sie in Zukunft mit der receiveDeferredMessage-Methode erneut zu empfangen.

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

Parameter

message

ServiceBusReceivedMessage

propertiesToModify

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

Die Eigenschaften der Zu ändernden Nachricht beim Zurückstellen der Nachricht

Gibt zurück

Promise<void>

getMessageIterator(GetMessageIteratorOptions)

Gibt einen Iterator zurück, der zum Empfangen von Nachrichten von Service Bus verwendet werden kann.

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

Parameter

options

GetMessageIteratorOptions

Eine Reihe von Optionen zum Steuern des Empfangsvorgangs.

• abortSignal: Das Signal, das zum Abbrechen des laufenden Vorgangs verwendet werden soll.

Gibt zurück

AsyncIterableIterator<ServiceBusReceivedMessage>

peekMessages(number, PeekMessagesOptions)

Werfen Sie einen Blick auf den nächsten Batch aktiver Nachrichten (einschließlich verzögerter, aber nicht inaktiver Nachrichten) in der Warteschlange oder im Abonnement, ohne sie zu ändern.

• Der erste Aufruf von peekMessages() ruft die erste aktive Nachricht ab. Jeder nachfolgende Aufruf ruft die nachfolgende Nachricht ab.
• Im Gegensatz zu einer "empfangenen" Nachricht ist die "Vorschau"-Nachricht eine schreibgeschützte Version der Nachricht. Es kann nicht Completed/Abandoned/Deferred/Deadletteredwerden.

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

Parameter

maxMessageCount

number

Die maximale Anzahl von Nachrichten, die angezeigt werden sollen.

options

PeekMessagesOptions

Optionen, mit denen die maximale Anzahl von Nachrichten angezeigt werden kann, die sequenceNumber zum Starten des Vorschauvorgangs oder eines AbortSignals zum Abbrechen des Vorgangs.

Gibt zurück

Promise<ServiceBusReceivedMessage[]>

receiveDeferredMessages(Long | Long[], OperationOptionsBase)

Gibt eine Zusage zurück, die in ein Array verzögerter Nachrichten aufgelöst wird, die durch die angegebene sequenceNumbersidentifiziert werden.

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

Parameter

sequenceNumbers

Long | Long[]

Die Sequenznummer oder ein Array von Sequenznummern für die Nachrichten, die empfangen werden müssen.

options

OperationOptionsBase

Optionsbehälter zum Übergeben von Abbruchsignal- oder Ablaufverfolgungsoptionen.

Gibt zurück

Promise<ServiceBusReceivedMessage[]>

Eine Liste von Nachrichten, die durch die angegebene SequenceNumbers oder eine leere Liste identifiziert werden, wenn keine Nachrichten gefunden werden.

receiveMessages(number, ReceiveMessagesOptions)

Gibt eine Zusage zurück, die in ein Array von Nachrichten aufgelöst wird, die von Service Bus empfangen wurden.

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

Parameter

maxMessageCount

number

Die maximale Anzahl der empfangenden Nachrichten.

options

ReceiveMessagesOptions

Eine Reihe von Optionen zum Steuern des Empfangsvorgangs.

• maxWaitTimeInMs: Die maximale Wartezeit für die erste Nachricht, bevor ein leeres Array zurückgegeben wird, wenn keine Nachrichten verfügbar sind.
• abortSignal: Das Signal, das zum Abbrechen des laufenden Vorgangs verwendet werden soll.

Gibt zurück

Promise<ServiceBusReceivedMessage[]>

Eine Zusage, die mit einem Array von Nachrichten aufgelöst wird.

renewMessageLock(ServiceBusReceivedMessage)

Erneuert die Sperre für die Nachricht für die Dauer, wie während der Erstellung der Warteschlange/des Abonnements angegeben.

• Überprüfen Sie die lockedUntilUtc Eigenschaft für die Nachricht, wann die Sperre abläuft.
• Wenn eine Nachricht nicht abgeschlossen ist (entweder mit complete(), defer() oder deadletter(), bevor die Sperre abläuft, landet die Nachricht wieder in der Warteschlange/im Abonnement für den nächsten Empfangsvorgang.

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

Parameter

message

ServiceBusReceivedMessage

Gibt zurück

Promise<Date>

Neues Ablaufdatum und -uhrzeit des Sperrtokens im UTC-Format.

subscribe(MessageHandlers, SubscribeOptions)

Streamt Nachrichten an Nachrichtenhandler.

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

Parameter

handlers

MessageHandlers

Ein Handler, der für Nachrichten und Fehler aufgerufen wird.

options

SubscribeOptions

Optionen für abonniert.

Gibt zurück

{ close() => Promise<void> }

Ein Objekt, das geschlossen werden kann und alle verbleibenden Nachrichten an handlers sendet und neue Nachrichten nicht mehr eintrifft.