Udostępnij za pośrednictwem


@azure/service-bus package

Klasy

MessagingError

Opisuje klasę podstawową dla błędu obsługi komunikatów.

ServiceBusAdministrationClient

Wszystkie operacje zwracają obietnice, które rozpoznają obiekt, który ma odpowiednie dane wyjściowe. Te obiekty mają również właściwość o nazwie _response , której można użyć, jeśli chcesz uzyskać dostęp do bezpośredniej odpowiedzi z usługi.

ServiceBusClient

Klient, który może tworzyć wystąpienia nadawcy do wysyłania komunikatów do kolejek i tematów, a także wystąpień odbiornika w celu odbierania komunikatów z kolejek i subskrypcji.

ServiceBusError

Błędy występujące w usłudze Service Bus.

Interfejsy

AuthorizationRule

Reprezentuje typ operacji zarządzania opartych AuthorizationRule na atomach.

CorrelationRuleFilter

Reprezentuje wyrażenie filtru korelacji. Właściwość CorrelationRuleFilter zawiera zestaw warunków, które są zgodne z właściwościami użytkownika i systemu przychodzących komunikatów z subskrypcji.

CreateMessageBatchOptions

Opcje konfigurowania createBatch metody w obiekcie Sender.

  • maxSizeInBytes: górny limit rozmiaru partii.

Przykład użycia:

{
    maxSizeInBytes: 1024 * 1024 // 1 MB
}
CreateQueueOptions

Reprezentuje opcje ustawiania w kolejce

CreateSubscriptionOptions

Reprezentuje opcje tabeli settable w subskrypcji

CreateTopicOptions

Reprezentuje opcje tabeli settable w temacie

DeadLetterOptions

Opisuje przyczynę i opis błędu dotyczący martwych komunikatów przy użyciu deadLetter() metody w komunikacie odebranym z usługi Service Bus.

Delivery
GetMessageIteratorOptions

Opcje podczas pobierania iterowalnego iteratora z usługi Service Bus.

HttpHeader

Pojedynczy nagłówek w kolekcji HttpHeaders.

HttpHeadersLike

Kolekcja par klucz/wartość nagłówka HTTP.

HttpResponse

Właściwości odpowiedzi HTTP, które zawsze będą obecne.

MessageHandlers

Ogólny interfejs obsługi komunikatów (używany do funkcji streamMessages).

NamespaceProperties

Reprezentuje metadane związane z przestrzenią nazw usługi Service Bus.

OperationOptions

Typ opcji podstawowych dla wszystkich operacji.

PeekMessagesOptions

Opisuje opcje przekazywane do metody w odbiorniku peekMessages .

ProcessErrorArgs

Argumenty wywołania zwrotnego processError .

QueueProperties

Reprezentuje dane wejściowe dla kolejki aktualizacji.

QueueRuntimeProperties

Reprezentuje atrybuty informacji o środowisku uruchomieniowym jednostki kolejki

ReceiveMessagesOptions

Opcje podczas odbierania partii komunikatów z usługi Service Bus.

RetryOptions

Opcje zasad ponawiania, które określają tryb, liczbę ponownych prób, interwał ponawiania prób itp.

RuleProperties

Reprezentuje wszystkie atrybuty reguły.

ServiceBusAdministrationClientOptions

Reprezentuje opcje klienta programu ServiceBusAdministrationClient.

ServiceBusClientOptions

Opisuje opcje, które można podać podczas tworzenia obiektu ServiceBusClient.

  • webSocketOptions : Opcje konfigurowania kanału połączenia AMQP za pośrednictwem gniazd internetowych.
    • websocket : Konstruktor protokołu WebSocket używany do tworzenia połączenia amQP, jeśli zdecydujesz się na połączenie za pośrednictwem protokołu WebSocket.
    • webSocketConstructorOptions : Opcje przekazywania do konstruktora protokołu Websocket podczas wybierania połączenia za pośrednictwem protokołu WebSocket.
  • retryOptions : opcje ponawiania dla wszystkich operacji na kliencie.
    • maxRetries : liczba ponownych prób operacji może zostać ponowiona w przypadku błędu możliwego do ponowienia próby.
    • maxRetryDelayInMs: maksymalne opóźnienie między ponawianiami prób. Dotyczy tylko w przypadku ponawiania prób wykładniczych.
    • mode: który tryb ponawiania prób ma być stosowany, określony przez wyliczenie RetryMode . Opcje to Exponential i Fixed. Wartość domyślna to Fixed.
    • retryDelayInMs: czas oczekiwania w milisekundach przed podjęciem następnej próby. Gdy mode jest ustawiona na Exponentialwartość , służy do obliczania wykładniczo rosnących opóźnień między ponownymi próbami. Wartość domyślna: 30000 milisekund.
    • timeoutInMs: czas oczekiwania w milisekundach przed przekroczeniem limitu czasu operacji. Spowoduje to wyzwolenie ponawiania próby w przypadku pozostałych prób ponawiania prób. Wartość minimalna: 60000 milisekund.
ServiceBusConnectionStringProperties

Zestaw właściwości składających się na parametry połączenia usługi Service Bus.

ServiceBusMessage

Opisuje komunikat, który ma zostać wysłany do usługi Service Bus.

ServiceBusMessageBatch

Partia komunikatów, które można utworzyć przy użyciu <xref:createBatch> metody .

ServiceBusReceivedMessage

Opisuje komunikat odebrany z usługi Service Bus podczas operacji wglądu i nie można go rozliczyć.

ServiceBusReceiver

Odbiornik, który nie obsługuje sesji.

ServiceBusReceiverOptions

Opcje do użycia podczas tworzenia odbiornika.

ServiceBusRuleManager

Zezwala na zarządzanie regułami subskrypcji. Ten menedżer reguł wymaga tylko oświadczeń nasłuchiwania, podczas gdy usługa ServiceBusAdministrationClient wymaga zarządzania oświadczeniami.

ServiceBusSender

Nadawca może służyć do wysyłania komunikatów, planowania wysyłania komunikatów w późniejszym czasie i anulowania takich zaplanowanych wiadomości. createSender Użyj funkcji w obiekcie ServiceBusClient, aby utworzyć wystąpienie nadawcy. Klasa Sender jest abstrakcją bazowego linku nadawcy AMQP.

ServiceBusSenderOptions

Opcje do użycia podczas tworzenia nadawcy.

ServiceBusSessionReceiver

Odbiornik obsługujący sesje, w tym odnawianie blokady sesji.

ServiceBusSessionReceiverOptions

Opisuje opcje przekazywane do acceptSession metod i acceptNextSession podczas korzystania z kolejki/subskrypcji z włączonymi sesjami.

SqlRuleFilter

Reprezentuje wszystkie możliwe pola w obiekcie SqlRuleFilter

SubscribeOptions

Opcje używane podczas subskrybowania kolejki lub subskrypcji usługi Service Bus.

SubscriptionProperties

Reprezentuje dane wejściowe dla parametru updateSubscription.

SubscriptionRuntimeProperties

Reprezentuje atrybuty informacji o środowisku uruchomieniowym jednostki subskrypcji

TokenCredential

Reprezentuje poświadczenie, które może zapewnić token uwierzytelniania.

TopicProperties

Reprezentuje dane wejściowe dla updateTopic.

TopicRuntimeProperties

Reprezentuje atrybuty informacji o środowisku uruchomieniowym jednostki tematu

TryAddOptions

Zestaw opcji do ręcznego propagowania Span kontekstu na potrzeby śledzenia rozproszonego.

WebResourceLike

Opis żądania HTTP, które ma zostać wykonane na serwerze zdalnym.

WebSocketImpl

Opisuje wymagany kształt konstruktorów WebSocket.

WebSocketOptions

Opcje konfigurowania kanału połączenia AMQP za pośrednictwem gniazd internetowych.

Aliasy typu

EntitiesResponse

Reprezentuje wynik operacji listy dla jednostek, które zawierają continuationToken również element , aby rozpocząć iterację od.

EntityAvailabilityStatus

Możliwe wartości jednostek availabilityStatus obsługi komunikatów usługi Service Bus.

EntityStatus

Możliwe wartości jednostek status obsługi komunikatów usługi Service Bus.

OperationOptionsBase

UWAGA: Ten typ jest przeznaczony do dublowania odpowiednich pól i struktury z @azure/core-client operacjiOptions

Opcje konfigurowania śledzenia i abortSignal.

RawHttpHeaders

Kolekcja HttpHeaders reprezentowana jako prosty obiekt JSON.

ServiceBusErrorCode

Kody błędów usługi Service Bus.

SqlRuleAction

Reprezentuje wszystkie możliwe pola w usłudze SqlRuleAction

TransferProgressEvent

Wyzwolony w odpowiedzi na postęp przekazywania lub pobierania.

WithResponse

Reprezentuje zwróconą odpowiedź operacji wraz z nieprzetworzonym odpowiedzią.

Wyliczenia

RetryMode

Opisuje typ trybu ponawiania prób

TokenType

Opisuje typ obsługiwanych tokenów.

Funkcje

delay<T>(number, AbortSignalLike, string, T)

Otoka setTimeout, która rozwiązuje obietnicę po t milisekundach.

isServiceBusError(unknown)

Określa, czy błąd jest typu ServiceBusError

parseServiceBusConnectionString(string)

Analizuje podane parametry połączenia do różnych właściwości mających zastosowanie do Azure Service Bus. Właściwości są przydatne do konstruowania obiektu ServiceBusClient.

Szczegóły funkcji

delay<T>(number, AbortSignalLike, string, T)

Otoka setTimeout, która rozwiązuje obietnicę po t milisekundach.

function delay<T>(delayInMs: number, abortSignal?: AbortSignalLike, abortErrorMsg?: string, value?: T): Promise<T | void>

Parametry

delayInMs

number

Liczba milisekund, które mają zostać opóźnione.

abortSignal
AbortSignalLike

Element abortSignal skojarzony z zawierającą operacją.

abortErrorMsg

string

Komunikat o błędzie przerwania skojarzony z operacją zawierającą.

value

T

Wartość, która ma zostać rozpoznana po przekroczeniu limitu czasu t milisekund.

Zwraca

Promise<T | void>

  • Rozwiązana obietnica

isServiceBusError(unknown)

Określa, czy błąd jest typu ServiceBusError

function isServiceBusError(err: unknown): err

Parametry

err

unknown

Błąd sprawdzania, czy jest to typ ServiceBusError

Zwraca

err

parseServiceBusConnectionString(string)

Analizuje podane parametry połączenia do różnych właściwości mających zastosowanie do Azure Service Bus. Właściwości są przydatne do konstruowania obiektu ServiceBusClient.

function parseServiceBusConnectionString(connectionString: string): ServiceBusConnectionStringProperties

Parametry

connectionString

string

Parametry połączenia skojarzone z zasadami dostępu współdzielonego utworzone dla przestrzeni nazw, kolejki lub tematu usługi Service Bus.

Zwraca