RequestResponseLink class
Menjelaskan tautan permintaan amqp(pengirim)-respons(penerima) yang dibuat melalui sesi amqp.
Konstruktor
| Request |
Properti
| connection | Menyediakan objek koneksi amqp yang mendasar. |
| receiver | |
| sender | |
| session |
Metode
| close() | Menutup tautan pengirim, penerima, dan sesi yang mendasar. |
| create(Connection, Sender |
Membuat tautan permintaan/respons amqp. |
| is |
Menunjukkan apakah sesi dan tautan pengirim dan penerima semuanya terbuka atau tertutup. |
| remove() | Menghapus tautan pengirim, penerima, dan sesi yang mendasar. |
| send |
Mengirim pesan permintaan yang diberikan dan mengembalikan respons yang diterima. Jika operasi tidak selesai dalam batas waktu yang disediakan dalam milidetik |
Detail Konstruktor
RequestResponseLink(Session, Sender, Receiver)
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
connection
Menyediakan objek koneksi amqp yang mendasar.
Connection connection
Nilai Properti
Connection
Sambungan.
receiver
receiver: Receiver
Nilai Properti
Receiver
sender
sender: Sender
Nilai Properti
Sender
session
session: Session
Nilai Properti
Session
Detail Metode
close()
Menutup tautan pengirim, penerima, dan sesi yang mendasar.
function close(): Promise<void>
Mengembalikan
Promise<void>
Janji<batal>
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })
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
Promise<RequestResponseLink>
Janji<PermintaanResponsTautan>
isOpen()
Menunjukkan apakah sesi dan tautan pengirim dan penerima semuanya terbuka atau tertutup.
function isOpen(): boolean
Mengembalikan
boolean
boolean - true - open, . false - closed
remove()
Menghapus tautan pengirim, penerima, dan sesi yang mendasar.
function remove()
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.
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).