مشاركة عبر


RequestResponseLink class

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

باطل الوعد<>

إنشاء ارتباط طلب/استجابة 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 قيد التقدم.

المرتجعات

طلب الوعدرابط<الاستجابة>

يشير إلى ما إذا كانت جلسة العمل وارتباطات المرسل والمتلقي كلها مفتوحة أو مغلقة.

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>

رسالة> الوعد<رسالة AMQP (الاستجابة).