CbsClient class

Pacote:

@azure/amqp-common

Construtores

CbsClient(Connection, string)

Propriedades

cbsLock	O nome do bloqueio unqiue por sessão $cbs por conexão que é usado para adquirir o bloqueio para estabelecer uma sessão cbs se não existir uma conexão aqmp.
connection	A conexão AMQP.
connectionLock	O nome do bloqueio unqiue por conexão que é usado para adquirir o bloqueio para estabelecer uma conexão amqp, caso não exista.
endpoint	Ponto final CBS - "$cbs"
replyTo	CBS replyTo - O nome do link do reciever ao qual o serviço deve responder.

Métodos

close()	Fecha a sessão cbs AMQP para o EventHub/ServiceBus para este cliente, retornando uma promessa que será resolvida quando a desconexão for concluída.
init()	Cria uma instância singleton da sessão CBS se ela não tiver sido inicializada anteriormente na conexão fornecida.
negotiateClaim(string, TokenInfo)	Negocia a reivindicação CBS com o Serviço EventHub/ServiceBus.
remove()	Remove a sessão cbs AMQP para o EventHub/ServiceBus para este cliente,

Detalhes do Construtor

CbsClient(Connection, string)

new CbsClient(connection: Connection, connectionLock: string)

Parâmetros

connection

Connection

A conexão AMQP.

connectionLock

string

Uma cadeia de caracteres exclusiva (geralmente um guid) por conexão.

Detalhes de Propriedade

cbsLock

O nome do bloqueio unqiue por sessão $cbs por conexão que é usado para adquirir o bloqueio para estabelecer uma sessão cbs se não existir uma conexão aqmp.

cbsLock: string

Valor de Propriedade

string

connection

A conexão AMQP.

connection: Connection

Valor de Propriedade

Connection

connectionLock

O nome do bloqueio unqiue por conexão que é usado para adquirir o bloqueio para estabelecer uma conexão amqp, caso não exista.

connectionLock: string

Valor de Propriedade

string

endpoint

Ponto final CBS - "$cbs"

endpoint: string

Valor de Propriedade

string

replyTo

CBS replyTo - O nome do link do reciever ao qual o serviço deve responder.

replyTo: string

Valor de Propriedade

string

Detalhes de Método

close()

Fecha a sessão cbs AMQP para o EventHub/ServiceBus para este cliente, retornando uma promessa que será resolvida quando a desconexão for concluída.

function close(): Promise<void>

Devoluções

Promise<void>

init()

Cria uma instância singleton da sessão CBS se ela não tiver sido inicializada anteriormente na conexão fornecida.

function init(): Promise<void>

Devoluções

Promise<void>

Promessa<vazia>.

negotiateClaim(string, TokenInfo)

Negocia a reivindicação CBS com o Serviço EventHub/ServiceBus.

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

Parâmetros

audience

string

O público do token de entidade para o qual o token é solicitado em uma das seguintes formas:

• ServiceBus

  • Remetente

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

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

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

• EventHubs

  • Remetente

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

  • Recetor

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

  • Management do Cliente

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

tokenObject

TokenInfo

O objeto token que precisa ser enviado na solicitação put-token.

Devoluções

Promise<CbsResponse>

Retorna uma Promise que resolve quando a autenticação $cbs é bem-sucedida e rejeita quando ocorre um erro durante $cbs autenticação.

remove()

Remove a sessão cbs AMQP para o EventHub/ServiceBus para este cliente,

function remove()