RequestResponseLink class
Describe un vínculo amqp request(sender)-response(receiver) que se crea a través de una sesión amqp.
Constructores
| Request |
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, Sender |
Crea un vínculo de solicitud/respuesta de amqp. |
| is |
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. |
| send |
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 |
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 receptor y la sesión subyacente.
function close(): Promise<void>
Devoluciones
Promise<void>
Promesa<nula>
create(Connection, SenderOptions, ReceiverOptions)
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
Promise<RequestResponseLink>
Promesa<RequestResponseLink>
isOpen()
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.
remove()
Quita el remitente, el vínculo receptor y la 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 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).