你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

RequestResponseLink class

描述通过 amqp 会话创建的 amqp 请求 (发送方) 响应 (接收方) 链接。

构造函数

RequestResponseLink(Session, Sender, Receiver)

属性

connection

提供基础 amqp 连接对象。

receiver
sender
session

方法

close()

关闭发送方、接收方链接和基础会话。

create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

创建 amqp 请求/响应链接。

isOpen()

指示会话以及发送方和接收方链接是全部打开还是关闭。

remove()

删除发送方、接收方链接及其基础会话。

sendRequest(Message, SendRequestOptions)

发送给定的请求消息并返回收到的响应。 如果在提供的超时(以毫秒 default: 60000为单位)中未完成操作,则会 OperationTimeoutError 引发 。

构造函数详细信息

new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver)

参数

session

Session

amqp 会话。

sender

Sender

amqp 发件人链接。

receiver

Receiver

amqp 接收方链接。

属性详细信息

提供基础 amqp 连接对象。

Connection connection

属性值

Connection

连接。

receiver: Receiver

属性值

Receiver

sender: Sender

属性值

Sender

session: Session

属性值

Session

方法详细信息

关闭发送方、接收方链接和基础会话。

function close(): Promise<void>

返回

Promise<void>

Promise

创建 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

指示会话以及发送方和接收方链接是全部打开还是关闭。

function isOpen(): boolean

返回

boolean

布尔值 - true - open、。 false - closed

删除发送方、接收方链接及其基础会话。

function remove()

发送给定的请求消息并返回收到的响应。 如果在提供的超时(以毫秒 default: 60000为单位)中未完成操作,则会 OperationTimeoutError 引发 。

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

参数

request

Message

AMQP (请求) 消息。

options
SendRequestOptions

发送请求时提供的选项。

返回

Promise<Message>

Promise AMQP (响应) 消息。