Compartir a través de


RequestResponseLink class

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 receptor y la sesión subyacente.

create(Connection, SenderOptions, ReceiverOptions)

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

isOpen()

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

remove()

Quita el remitente, el vínculo receptor y la 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 segundos default: 10, la solicitud se reintentará linealmente para el número proporcionado de veces default: 3 con el retraso proporcionado en segundos default: 15 entre cada intento.

Detalles del constructor

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

Proporciona el objeto de conexión amqp subyacente.

connection: Connection

Valor de propiedad

Connection

Conexión.

receiver: Receiver

Valor de propiedad

Receiver

sender: Sender

Valor de propiedad

Sender

session: Session

Valor de propiedad

Session

Detalles del método

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

function close(): Promise<void>

Devoluciones

Promise<void>

Promesa<nula>

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

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions): 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 receptor.

Devoluciones

Promesa<RequestResponseLink>

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

function isOpen(): boolean

Devoluciones

boolean

boolean: true - open, false - closed.

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

function remove()

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 segundos default: 10, la solicitud se reintentará linealmente para el número proporcionado de veces default: 3 con el retraso proporcionado en segundos default: 15 entre cada intento.

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

Parámetros

request
AmqpMessage

Mensaje AMQP (solicitud).

options
SendRequestOptions

Opciones que se pueden proporcionar al enviar una solicitud.

Devoluciones

Promise<AmqpMessage>

Mensaje< de promesa>El mensaje AMQP (respuesta).