RequestResponseLink class
描述通过 amqp 会话创建的 amqp 请求（sender）-response（接收方）链接。
属性
| connection | 提供基础 amqp 连接对象。 |
| receiver | |
| sender | |
| session |
方法
| close() | 关闭发送方、接收方链接和基础会话。 |
| create(Connection, Sender |
创建 amqp 请求/响应链接。 |
| is |
指示会话和发送方和接收方链接是全部打开还是关闭。 |
| remove() | 删除发送方、接收方链接及其基础会话。 |
| send |
发送给定的请求消息并返回收到的响应。 如果在提供的超时（以毫秒为单位） |
构造函数详细信息
RequestResponseLink(Session, Sender, Receiver)
new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver)参数
- session
-
Session
amqp 会话。
- sender
-
Sender
amqp 发件人链接。
- receiver
-
Receiver
amqp 接收方链接。
属性详细信息
connection
提供基础 amqp 连接对象。
Connection connection属性值
Connection
连接。
receiver
receiver: Receiver属性值
Receiver
sender
sender: Sender属性值
Sender
session
session: Session属性值
Session
方法详细信息
close()
关闭发送方、接收方链接和基础会话。
function close(): Promise<void>返回
Promise<void>
承诺<无效>
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
创建 amqp 请求/响应链接。
static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>参数
- connection
-
Connection
amqp 连接。
- senderOptions
-
SenderOptions
必须提供用于创建发件人链接的选项。
- receiverOptions
-
ReceiverOptions
必须提供用于创建接收方链接的选项。
- createOptions
-
{ abortSignal?: AbortSignalLike }
可用于影响此方法行为的可选参数。
例如，可以传递 abortSignal 以允许取消正在进行的 create 调用。
返回
Promise<RequestResponseLink>
承诺<RequestResponseLink>
isOpen()
指示会话和发送方和接收方链接是全部打开还是关闭。
function isOpen(): boolean返回
boolean
boolean - true - open，false - closed。
remove()
删除发送方、接收方链接及其基础会话。
function remove()
sendRequest(Message, SendRequestOptions)
发送给定的请求消息并返回收到的响应。 如果在提供的超时（以毫秒为单位）default: 60000中未完成该作，则会引发 OperationTimeoutError。
function sendRequest(request: Message, options?: SendRequestOptions): Promise<Message>参数
- request
-
Message
AMQP（请求）消息。
- options
- SendRequestOptions
发送请求时可以提供的选项。
返回
Promise<Message>
承诺<消息> AMQP（响应）消息。