Bagikan melalui


RequestResponseLink class

Menjelaskan tautan permintaan amqp(pengirim)-respons(penerima) yang dibuat melalui sesi amqp.

Konstruktor

RequestResponseLink(Session, Sender, Receiver)

Properti

connection

Menyediakan objek koneksi amqp yang mendasar.

receiver
sender
session

Metode

close()

Menutup tautan pengirim, penerima, dan sesi yang mendasar.

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

Membuat tautan permintaan/respons amqp.

isOpen()

Menunjukkan apakah sesi dan tautan pengirim dan penerima semuanya terbuka atau tertutup.

remove()

Menghapus tautan pengirim, penerima, dan sesi yang mendasar.

sendRequest(Message, SendRequestOptions)

Mengirim pesan permintaan yang diberikan dan mengembalikan respons yang diterima. Jika operasi tidak selesai dalam batas waktu yang disediakan dalam milidetik default: 60000, maka OperationTimeoutError dilemparkan.

Detail Konstruktor

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

Parameter

session

Session

Sesi amqp.

sender

Sender

Tautan pengirim amqp.

receiver

Receiver

Tautan penerima amqp.

Detail Properti

Menyediakan objek koneksi amqp yang mendasar.

Connection connection

Nilai Properti

Connection

Sambungan.

receiver: Receiver

Nilai Properti

Receiver

sender: Sender

Nilai Properti

Sender

session: Session

Nilai Properti

Session

Detail Metode

Menutup tautan pengirim, penerima, dan sesi yang mendasar.

function close(): Promise<void>

Mengembalikan

Promise<void>

Janji<batal>

Membuat tautan permintaan/respons amqp.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>

Parameter

connection

Connection

Koneksi amqp.

senderOptions

SenderOptions

Opsi yang harus disediakan untuk membuat tautan pengirim.

receiverOptions

ReceiverOptions

Opsi yang harus disediakan untuk membuat tautan penerima.

createOptions

{ abortSignal?: AbortSignalLike }

Parameter opsional yang dapat digunakan untuk memengaruhi perilaku metode ini. Misalnya, abortSignal dapat diteruskan untuk memungkinkan pembatalan pemanggilan create yang sedang berlangsung.

Mengembalikan

Janji<PermintaanResponsTautan>

Menunjukkan apakah sesi dan tautan pengirim dan penerima semuanya terbuka atau tertutup.

function isOpen(): boolean

Mengembalikan

boolean

boolean - true - open, . false - closed

Menghapus tautan pengirim, penerima, dan sesi yang mendasar.

function remove()

Mengirim pesan permintaan yang diberikan dan mengembalikan respons yang diterima. Jika operasi tidak selesai dalam batas waktu yang disediakan dalam milidetik default: 60000, maka OperationTimeoutError dilemparkan.

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

Parameter

request

Message

Pesan AMQP (permintaan).

options
SendRequestOptions

Opsi yang dapat disediakan saat mengirim permintaan.

Mengembalikan

Promise<Message>

Pesan Janji<> Pesan AMQP (respons).