RequestResponseLink class
يصف ارتباط amqp request(sender)-response(receiver) الذي تم إنشاؤه عبر جلسة amqp.
الخصائص
| 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>
باطل الوعد<>
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>
طلب الوعدرابط<الاستجابة>
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>
رسالة> الوعد<رسالة AMQP (الاستجابة).