共用方式為


RequestResponseLink class

描述透過amqp會話建立的amqp要求(sender)-response(receiver) 連結。

建構函式

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>

承諾<無效>

建立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 調用。

傳回

承諾<RequestResponseLink>

指出工作階段和傳送者和接收者連結是否全部開啟或關閉。

function isOpen(): boolean

傳回

boolean

布林值 - true - openfalse - closed

拿掉傳送者、接收者連結,而且它是基礎會話。

function remove()

傳送指定的要求訊息,並傳回收到的回應。 如果在提供的逾時中未完成作業,以毫秒為單位 default: 60000,則會擲回 OperationTimeoutError

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

參數

request

Message

AMQP (要求) 訊息。

options
SendRequestOptions

可在傳送要求時提供的選項。

傳回

Promise<Message>

承諾<消息> AMQP(回應)消息。