你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
RequestResponseLink class
描述通过 amqp 会话创建的 amqp 请求 (发送方) 响应 (接收方) 链接。
构造函数
Request |
属性
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>
Promise
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>
Promise
isOpen()
指示会话以及发送方和接收方链接是全部打开还是关闭。
function isOpen(): 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>
Promise AMQP (响应) 消息。