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 milisegundos |
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, { 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 receptor.
- createOptions
-
{ abortSignal?: AbortSignalLike }
Parámetros opcionales que se pueden usar para afectar al comportamiento de este método.
Por ejemplo, se puede pasar abortSignal para permitir la cancelación de una invocación en curso create.
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 milisegundos default: 60000, se produce OperationTimeoutError.
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>
Mensaje> de promesa<El mensaje AMQP (respuesta).