RequestResponseLink class

Paket:

@azure/core-amqp

Bir amqp oturumu üzerinden oluşturulan bir amqp isteği (gönderen)-yanıt(alıcı) bağlantısını açıklar.

Oluşturucular

RequestResponseLink(Session, Sender, Receiver)

Özellikler

connection	Temel amqp bağlantı nesnesini sağlar.
receiver
sender
session

Yöntemler

close()	Göndereni, alıcı bağlantısını ve temel alınan oturumu kapatır.
create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })	Bir amqp isteği/yanıt bağlantısı oluşturur.
isOpen()	Oturumun, gönderen ve alıcı bağlantılarının tümünün açık mı yoksa kapalı mı olduğunu gösterir.
remove()	Göndereni, alıcı bağlantısını kaldırır ve temel oturumunu kaldırır.
sendRequest(Message, SendRequestOptions)	Verilen istek iletisini gönderir ve alınan yanıtı döndürür. sağlanan zaman aşımında işlem milisaniye default: 60000tamamlanmazsa OperationTimeoutError oluşturulur.

Oluşturucu Ayrıntıları

RequestResponseLink(Session, Sender, Receiver)

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

Parametreler

session

Session

Amqp oturumu.

sender

Sender

amqp gönderen bağlantısı.

receiver

Receiver

Amqp alıcı bağlantısı.

Özellik Ayrıntıları

connection

Temel amqp bağlantı nesnesini sağlar.

Connection connection

Özellik Değeri

Connection

Bağlantı.

receiver

receiver: Receiver

Özellik Değeri

Receiver

sender

sender: Sender

Özellik Değeri

Sender

session

session: Session

Özellik Değeri

Session

Yöntem Ayrıntıları

close()

Göndereni, alıcı bağlantısını ve temel alınan oturumu kapatır.

function close(): Promise<void>

Döndürülenler

Promise<void>

Söz<geçersiz>

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

Bir amqp isteği/yanıt bağlantısı oluşturur.

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

Parametreler

connection

Connection

Amqp bağlantısı.

senderOptions

SenderOptions

Gönderen bağlantısını oluşturmak için sağlanması gereken seçenekler.

receiverOptions

ReceiverOptions

Alıcı bağlantısını oluşturmak için sağlanması gereken seçenekler.

createOptions

{ abortSignal?: AbortSignalLike }

Bu yöntemin davranışını etkilemek için kullanılabilecek isteğe bağlı parametreler. Örneğin, devam eden bir abortSignal çağrının iptal edilmesine izin vermek için create geçirilebilir.

Döndürülenler

Promise<RequestResponseLink>

Söz<RequestResponseLink>

isOpen()

Oturumun, gönderen ve alıcı bağlantılarının tümünün açık mı yoksa kapalı mı olduğunu gösterir.

function isOpen(): boolean

Döndürülenler

boolean

boolean - true - open, false - closed.

remove()

Göndereni, alıcı bağlantısını kaldırır ve temel oturumunu kaldırır.

function remove()

sendRequest(Message, SendRequestOptions)

Verilen istek iletisini gönderir ve alınan yanıtı döndürür. sağlanan zaman aşımında işlem milisaniye default: 60000tamamlanmazsa OperationTimeoutError oluşturulur.

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

Parametreler

request

Message

AMQP (istek) iletisi.

options

SendRequestOptions

İstek gönderilirken sağlanabilir seçenekler.

Döndürülenler

Promise<Message>

Söz<İletisi> : AMQP (yanıt) iletisi.