CbsClient class

Paket:
@azure/amqp-common

Oluşturucular

CbsClient(Connection, string)

Özellikler

cbsLock

Aqmp bağlantısı için mevcut değilse cbs oturumu oluşturmak için kilidi almak için kullanılan bağlantı başına $cbs oturum başına kilit adı.
connection

AMQP bağlantısı.
connectionLock

Mevcut değilse amqp bağlantısı kurmak için kilidi almak için kullanılan bağlantı başına unqiue kilit adı.
endpoint

CBS uç noktası - "$cbs"
replyTo

CBS replyTo - Hizmetin yanıtlaması gereken geri dönüş bağlantı adı.

Yöntemler

close()

AmQP cbs oturumunu bu istemci için EventHub/ServiceBus'a kapatır ve bağlantı kesilmesi tamamlandığında çözülecek bir söz döndürür.
init()

Verilen bağlantıda daha önce başlatılmadıysa CBS oturumunun tek bir örneğini oluşturur.
negotiateClaim(string, TokenInfo)

CBS talebi için EventHub/ServiceBus Hizmeti ile anlaşma sağlar.
remove()

Bu istemci için EventHub/ServiceBus'ta AMQP cbs oturumunu kaldırır,

Oluşturucu Ayrıntıları

CbsClient(Connection, string) 

new CbsClient(connection: Connection, connectionLock: string)

Parametreler

connection

Connection

AMQP işlevi.

connectionLock

string

Bağlantı başına benzersiz bir dize (genellikle guid).

Özellik Ayrıntıları

cbsLock

Aqmp bağlantısı için mevcut değilse cbs oturumu oluşturmak için kilidi almak için kullanılan bağlantı başına $cbs oturum başına kilit adı.

cbsLock: string

Özellik Değeri

string

connection

AMQP bağlantısı.

connection: Connection

Özellik Değeri

Connection

connectionLock

Mevcut değilse amqp bağlantısı kurmak için kilidi almak için kullanılan bağlantı başına unqiue kilit adı.

connectionLock: string

Özellik Değeri

string

endpoint

CBS uç noktası - "$cbs"

endpoint: string

Özellik Değeri

string

replyTo

CBS replyTo - Hizmetin yanıtlaması gereken geri dönüş bağlantı adı.

replyTo: string

Özellik Değeri

string

Yöntem Ayrıntıları

close()

AmQP cbs oturumunu bu istemci için EventHub/ServiceBus'a kapatır ve bağlantı kesilmesi tamamlandığında çözülecek bir söz döndürür.

function close(): Promise<void>

Döndürülenler

Promise<void>

init()

Verilen bağlantıda daha önce başlatılmadıysa CBS oturumunun tek bir örneğini oluşturur.

function init(): Promise<void>

Döndürülenler

Promise<void>

Söz<geçersiz>.

negotiateClaim(string, TokenInfo)

CBS talebi için EventHub/ServiceBus Hizmeti ile anlaşma sağlar.

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

Parametreler

audience

string

Aşağıdaki formlardan birinde belirtecin istendiği varlık belirteci hedef kitlesi:

  • ServiceBus

    • Gönderen

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

    • alıcı "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

    • Gönderen

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

    • Alıcı

      • "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

Put-token isteğinde gönderilmesi gereken belirteç nesnesi.

Döndürülenler

Promise<CbsResponse>

$cbs kimlik doğrulaması başarılı olduğunda çözümleyen ve $cbs kimlik doğrulaması sırasında bir hata oluştuğunda reddeden bir Promise döndürür.

remove()

Bu istemci için EventHub/ServiceBus'ta AMQP cbs oturumunu kaldırır,

function remove()