@azure/core-amqp package

Describes the EventHub/ServiceBus Cbs client that talks to the $cbs endpoint over AMQP connection.

Describes the base class for Messaging Error.

Describes an amqp request(sender)-response(receiver) link that is created over an amqp session.

Describes the properties that must be provided while acquiring a lock.

Describes the AmqpAnnotatedMessage, part of the ServiceBusReceivedMessage(as amqpAnnotatedMessage property).

Describes the defined set of standard header properties of the message.

Describes the defined set of standard properties of the message.

CancellableAsyncLock provides a mechanism for forcing tasks using the same 'key' to be executed serially.

Pending tasks can be manually cancelled via an abortSignal or automatically cancelled by reach a provided timeout value.

Describes the CBS Response.

Describes the connection config object that is created after parsing an EventHub or ServiceBus connection string.

Describes the options that can be provided while creating a connection config.

Provides contextual information like the underlying amqp connection, cbs session, tokenProvider, Connection config, data transformer, etc.

Defines the properties that need to be set while establishing the AMQP connection.

Describes the parameters that can be provided to create the base connection context.

Describes the fields on a Node.js SystemError. Omits fields that are not related to network calls (e.g. file system calls). See https://nodejs.org/dist/latest-v12.x/docs/api/errors.html#errors_class_systemerror

Describes the parameters that need to be configured for the retry operation.

Retry policy options that determine the mode, number of retries, retry interval etc.

Describes the options that can be specified while sending a request.

Options to configure the channelling of the AMQP connection over Web Sockets.

Defines an object with possible properties defined in T.

Maps the amqp error conditions to the Error names.

Maps the Error names to the amqp error conditions.

Describes the Retry Mode type

Describes the retry operation type.

Maps some SystemErrors to amqp error conditions

Describes the type of supported tokens.

A wrapper for setTimeout that resolves a promise after t milliseconds.

Determines if an error is a MessagingError.

Checks whether the provided error is a node.js SystemError.

Parses the connection string and returns an object of type T.

Connection strings have the following syntax:

ConnectionString ::= Part { ";" Part } [ ";" ] [ WhiteSpace ] Part ::= [ PartLiteral [ "=" PartLiteral ] ] PartLiteral ::= [ WhiteSpace ] Literal [ WhiteSpace ] Literal ::= ? any sequence of characters except ; or = or WhiteSpace ? WhiteSpace ::= ? all whitespace characters including \r and \n ?

Every operation is attempted at least once. Additional attempts are made if the previous attempt failed with a retryable error. The number of additional attempts is governed by the maxRetries property provided on the RetryConfig argument.

If mode option is set to Fixed, then the retries are made on the given operation for a specified number of times, with a fixed delay in between each retry each time.

If mode option is set to Exponential, then the delay between retries is adjusted to increase exponentially with each attempt using back-off factor of power 2.

Translates the AMQP error received at the protocol layer or a SystemError into a MessagingError. All other errors are returned unaltered.