@azure/core-amqp package

Descreve o cliente EventHub/ServiceBus Cbs que conversa com o ponto de extremidade $cbs pela conexão AMQP.

Descreve a classe base para Erro de Mensagens.

Descreve um link amqp request(sender)-response(receiver) criado em uma sessão amqp.

Descreve as propriedades que devem ser fornecidas durante a aquisição de um bloqueio.

Descreve o AmqpAnnotatedMessage, parte da propriedade ServiceBusReceivedMessage(as amqpAnnotatedMessage).

Descreve o conjunto definido de propriedades de cabeçalho padrão da mensagem.

Descreve o conjunto definido de propriedades padrão da mensagem.

CancellableAsyncLock fornece um mecanismo para forçar tarefas usando a mesma "chave" a serem executadas serialmente.

Tarefas pendentes podem ser canceladas manualmente por meio de um abortSignal ou canceladas automaticamente, atingindo um valor de tempo limite fornecido.

Descreve a resposta da CBS.

Descreve o objeto de configuração de conexão criado após a análise de uma cadeia de conexão EventHub ou ServiceBus.

Descreve as opções que podem ser fornecidas durante a criação de uma configuração de conexão.

Fornece informações contextuais, como a conexão amqp subjacente, sessão cbs, tokenProvider, configuração de conexão, transformador de dados etc.

Define as propriedades que precisam ser definidas ao estabelecer a conexão AMQP.

Descreve os parâmetros que podem ser fornecidos para criar o contexto de conexão base.

Descreve os campos em uma Node.js SystemError. Omite campos que não estão relacionados a chamadas de rede (por exemplo, chamadas do sistema de arquivos). Consulte https://nodejs.org/dist/latest-v12.x/docs/api/errors.html#errors_class_systemerror

Descreve os parâmetros que precisam ser configurados para a operação de repetição.

Opções de política de repetição que determinam o modo, o número de repetições, o intervalo de repetição etc.

Descreve as opções que podem ser especificadas ao enviar uma solicitação.

Opções para configurar a canalização da conexão AMQP por meio de Soquetes Web.

Define um objeto com possíveis propriedades definidas em T.

Mapeia as condições de erro amqp para os nomes de erro.

Mapeia os nomes de erro para as condições de erro amqp.

Descreve o tipo de Modo de Repetição

Descreve o tipo de operação de repetição.

Mapeia alguns SystemErrors para condições de erro amqp

Descreve o tipo de tokens com suporte.

Um wrapper para setTimeout que resolve uma promessa após milissegundos.

Determina se um erro é um MessagingError.

Verifica se o erro fornecido é uma node.js SystemError.

Analisa a cadeia de conexão e retorna um objeto do tipo T.

As cadeias de conexão têm a seguinte sintaxe:

ConnectionString ::= Part { ";" Part } [ ";" ] [ WhiteSpace ] Parte ::= [ PartLiteral [ "=" PartLiteral ] ] PartLiteral ::= [ WhiteSpace ] Literal [ WhiteSpace ] Literal ::= ? qualquer sequência de caracteres, exceto ; ou = ou WhiteSpace? Espaço em branco ::= ? todos os caracteres de espaço em branco, incluindo \r e \n?

Todas as operações são tentadas pelo menos uma vez. Tentativas adicionais são feitas se a tentativa anterior falhou com um erro retrátivel. O número de tentativas adicionais é regido pela propriedade maxRetries fornecida no argumento RetryConfig.

Se mode opção estiver definida como Fixed, as novas tentativas serão feitas na operação determinada por um número especificado de vezes, com um atraso fixo entre cada repetição a cada vez.

Se mode opção estiver definida como Exponential, o atraso entre novas tentativas será ajustado para aumentar exponencialmente com cada tentativa usando o fator de retirada da potência 2.

Converte o erro AMQP recebido na camada de protocolo ou em um SystemError em um MessagingError. Todos os outros erros são retornados sem filtro.