Dela via


RequestResponseLink class

Beskriver en amqp request(sender)-response(receiver)-länk som skapas över en amqp-session.

Konstruktorer

RequestResponseLink(Session, Sender, Receiver)

Egenskaper

connection

Tillhandahåller det underliggande amqp-anslutningsobjektet.

receiver
sender
session

Metoder

close()

Stänger avsändaren, mottagarlänken och den underliggande sessionen.

create(Connection, SenderOptions, ReceiverOptions)

Skapar en amqp-länk för begäran/svar.

isOpen()

Anger om sessionen och avsändar- och mottagarlänkarna är öppna eller stängda.

remove()

Tar bort avsändaren, mottagarlänken och den underliggande sessionen.

sendRequest(Message, SendRequestOptions)

Skickar det angivna begärandemeddelandet och returnerar det mottagna svaret. Om åtgärden inte har slutförts i den angivna tidsgränsen i sekunder default: 10kommer begäran att utföras linjärt igen för det angivna antalet gånger default: 3 med den angivna fördröjningen i sekunder default: 15 mellan varje försök.

Konstruktorinformation

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

Parametrar

session

Session

Amqp-sessionen.

sender

Sender

Länken för amqp-avsändare.

receiver

Receiver

Länken för amqp-mottagare.

Egenskapsinformation

Tillhandahåller det underliggande amqp-anslutningsobjektet.

connection: Connection

Egenskapsvärde

Connection

Anslutning.

receiver: Receiver

Egenskapsvärde

Receiver

sender: Sender

Egenskapsvärde

Sender

session: Session

Egenskapsvärde

Session

Metodinformation

Stänger avsändaren, mottagarlänken och den underliggande sessionen.

function close(): Promise<void>

Returer

Promise<void>

Löfte

Skapar en amqp-länk för begäran/svar.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions): Promise<RequestResponseLink>

Parametrar

connection

Connection

Amqp-anslutningen.

senderOptions

SenderOptions

Alternativ som måste anges för att skapa avsändarlänken.

receiverOptions

ReceiverOptions

Alternativ som måste anges för att skapa mottagarlänken.

Returer

Löfte

Anger om sessionen och avsändar- och mottagarlänkarna är öppna eller stängda.

function isOpen(): boolean

Returer

boolean

booleskt - true - open, . false - closed

Tar bort avsändaren, mottagarlänken och den underliggande sessionen.

function remove()

Skickar det angivna begärandemeddelandet och returnerar det mottagna svaret. Om åtgärden inte har slutförts i den angivna tidsgränsen i sekunder default: 10kommer begäran att utföras linjärt igen för det angivna antalet gånger default: 3 med den angivna fördröjningen i sekunder default: 15 mellan varje försök.

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

Parametrar

request
AmqpMessage

AMQP-meddelandet (begäran).

options
SendRequestOptions

Alternativ som kan anges när en begäran skickas.

Returer

Promise<AmqpMessage>

Promise AMQP-meddelandet (svar).