CbsClient class

Paket:

@azure/amqp-common

Konstruktoren

CbsClient(Connection, string)

Eigenschaften

cbsLock	Der unzulässige Sperrname pro $cbs Sitzung pro Verbindung, die zum Abrufen der Sperre zum Herstellen einer cbs-Sitzung verwendet wird, wenn eine für eine Aqmp-Verbindung nicht vorhanden ist.
connection	Die AMQP-Verbindung.
connectionLock	Der unzulässige Sperrname pro Verbindung, der zum Abrufen der Sperre zum Herstellen einer amqp-Verbindung verwendet wird, wenn keine vorhanden ist.
endpoint	CBS-Endpunkt – "$cbs"
replyTo	CBS replyTo – Der Name des Empfängerlinks, auf den der Dienst antworten soll.

Methoden

close()	Schließt die AMQP cbs-Sitzung an den EventHub/ServiceBus für diesen Client, und gibt eine Zusage zurück, die aufgelöst wird, wenn die Verbindung abgeschlossen ist.
init()	Erstellt eine Singleton-Instanz der CBS-Sitzung, wenn sie zuvor für die angegebene Verbindung noch nicht initialisiert wurde.
negotiateClaim(string, TokenInfo)	Verhandelt den CBS-Anspruch mit dem EventHub/ServiceBus-Dienst.
remove()	Entfernt die AMQP cbs-Sitzung für diesen Client zum EventHub/ServiceBus.

Details zum Konstruktor

CbsClient(Connection, string)

new CbsClient(connection: Connection, connectionLock: string)

Parameter

connection

Connection

Die AMQP-Konsektion.

connectionLock

string

Eine eindeutige Zeichenfolge (in der Regel eine GUID) pro Verbindung.

Details zur Eigenschaft

cbsLock

Der unzulässige Sperrname pro $cbs Sitzung pro Verbindung, die zum Abrufen der Sperre zum Herstellen einer cbs-Sitzung verwendet wird, wenn eine für eine Aqmp-Verbindung nicht vorhanden ist.

cbsLock: string

Eigenschaftswert

string

connection

Die AMQP-Verbindung.

connection: Connection

Eigenschaftswert

Connection

connectionLock

Der unzulässige Sperrname pro Verbindung, der zum Abrufen der Sperre zum Herstellen einer amqp-Verbindung verwendet wird, wenn keine vorhanden ist.

connectionLock: string

Eigenschaftswert

string

endpoint

CBS-Endpunkt – "$cbs"

endpoint: string

Eigenschaftswert

string

replyTo

CBS replyTo – Der Name des Empfängerlinks, auf den der Dienst antworten soll.

replyTo: string

Eigenschaftswert

string

Details zur Methode

close()

Schließt die AMQP cbs-Sitzung an den EventHub/ServiceBus für diesen Client, und gibt eine Zusage zurück, die aufgelöst wird, wenn die Verbindung abgeschlossen ist.

function close(): Promise<void>

Gibt zurück

Promise<void>

init()

Erstellt eine Singleton-Instanz der CBS-Sitzung, wenn sie zuvor für die angegebene Verbindung noch nicht initialisiert wurde.

function init(): Promise<void>

Gibt zurück

Promise<void>

Leere Verheißung<>.

negotiateClaim(string, TokenInfo)

Verhandelt den CBS-Anspruch mit dem EventHub/ServiceBus-Dienst.

function negotiateClaim(audience: string, tokenObject: TokenInfo): Promise<CbsResponse>

Parameter

audience

string

Die Entitätstokengruppe, für die das Token in einem der folgenden Formen angefordert wird:

• ServiceBus-

  • Absender-

    • "sb://<yournamespace>.servicebus.windows.net/<queue-name>"
    • "sb://<yournamespace>.servicebus.windows.net/<topic-name>"

  • Empfänger- - "sb://<yournamespace>.servicebus.windows.net/<queue-name>" - "sb://<yournamespace>.servicebus.windows.net/<topic-name>"

  • ManagementClient - "sb://<your-namespace>.servicebus.windows.net/<queue-name>/$management". - "sb://<your-namespace>.servicebus.windows.net/<topic-name>/$management".

• EventHubs-

  • Absender-

    • "sb://<yournamespace>.servicebus.windows.net/<hubName>"
    • "sb://<yournamespace>.servicebus.windows.net/<hubName>/Partitions/<partitionId>".

  • Empfänger-

    • "sb://<your-namespace>.servicebus.windows.net/<event-hub-name>/ConsumerGroups/<consumer-group-name>/Partitions/<partition-id>".

  • ManagementClient-

    • "sb://<your-namespace>.servicebus.windows.net/<event-hub-name>/$management".

tokenObject

TokenInfo

Das Tokenobjekt, das in der Put-Token-Anforderung gesendet werden muss.

Gibt zurück

Promise<CbsResponse>

Gibt eine Zusage zurück, die aufgelöst wird, wenn $cbs Authentifizierung erfolgreich ist und ablehnt, wenn während $cbs Authentifizierung ein Fehler auftritt.

remove()

Entfernt die AMQP cbs-Sitzung für diesen Client zum EventHub/ServiceBus.

function remove()