RequestResponseLink class

Paquete:

@azure/core-amqp

Describe un vínculo amqp request(sender)-response(receiver) que se crea a través de una sesión amqp.

Constructores

RequestResponseLink(Session, Sender, Receiver)

Propiedades

connection	Proporciona el objeto de conexión amqp subyacente.
receiver
sender
session

Métodos

close()	Cierra el remitente, el vínculo del receptor y la sesión subyacente.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Crea un vínculo de solicitud/respuesta de amqp.
isOpen()	Indica si la sesión y los vínculos remitente y receptor están abiertos o cerrados.
remove()	Quita el remitente, el vínculo del receptor y su sesión subyacente.
sendRequest(Message, SendRequestOptions)	Envía el mensaje de solicitud especificado y devuelve la respuesta recibida. Si la operación no se completa en el tiempo de espera proporcionado en milisegundos default: 60000, OperationTimeoutError se inicia .

Detalles del constructor

RequestResponseLink(Session, Sender, Receiver)

new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver)

Parámetros

session

Session

Sesión amqp.

sender

Sender

Vínculo del remitente amqp.

receiver

Receiver

Vínculo del receptor amqp.

Detalles de las propiedades

connection

Proporciona el objeto de conexión amqp subyacente.

Connection connection

Valor de propiedad

Connection

Conexión.

receiver

receiver: Receiver

Valor de propiedad

Receiver

sender

sender: Sender

Valor de propiedad

Sender

session

session: Session

Valor de propiedad

Session

Detalles del método

close()

Cierra el remitente, el vínculo del receptor y la sesión subyacente.

function close(): Promise<void>

Devoluciones

Promise<void>

Promesa

create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

Crea un vínculo de solicitud/respuesta de amqp.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>

Parámetros

connection

Connection

Conexión amqp.

senderOptions

SenderOptions

Opciones que se deben proporcionar para crear el vínculo del remitente.

receiverOptions

ReceiverOptions

Opciones que se deben proporcionar para crear el vínculo del receptor.

createOptions

{ abortSignal?: AbortSignalLike }

Parámetros opcionales que se pueden usar para afectar al comportamiento de este método. Por ejemplo, abortSignal se puede pasar para permitir la cancelación de una invocación en curso create .

Devoluciones

Promise<RequestResponseLink>

Promesa

isOpen()

Indica si la sesión y los vínculos remitente y receptor están abiertos o cerrados.

function isOpen(): boolean

Devoluciones

boolean

booleano: true - open, false - closed.

remove()

Quita el remitente, el vínculo del receptor y su sesión subyacente.

function remove()

sendRequest(Message, SendRequestOptions)

Envía el mensaje de solicitud especificado y devuelve la respuesta recibida. Si la operación no se completa en el tiempo de espera proporcionado en milisegundos default: 60000, OperationTimeoutError se inicia .

function sendRequest(request: Message, options?: SendRequestOptions): Promise<Message>

Parámetros

request

Message

Mensaje AMQP (solicitud).

options

SendRequestOptions

Opciones que se pueden proporcionar al enviar una solicitud.

Devoluciones

Promise<Message>

Promete el mensaje AMQP (respuesta).