RequestResponseLink class
Beskriver en amqp request(sender)-response(receiver)-länk som skapas över en amqp-session.
Konstruktorer
Request |
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, Sender |
Skapar en amqp-länk för begäran/svar. |
is |
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. |
send |
Skickar det angivna begärandemeddelandet och returnerar det mottagna svaret. Om åtgärden inte har slutförts i den angivna tidsgränsen i sekunder |
Konstruktorinformation
RequestResponseLink(Session, Sender, Receiver)
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
connection
Tillhandahåller det underliggande amqp-anslutningsobjektet.
connection: Connection
Egenskapsvärde
Connection
Anslutning.
receiver
receiver: Receiver
Egenskapsvärde
Receiver
sender
sender: Sender
Egenskapsvärde
Sender
session
session: Session
Egenskapsvärde
Session
Metodinformation
close()
Stänger avsändaren, mottagarlänken och den underliggande sessionen.
function close(): Promise<void>
Returer
Promise<void>
Löfte
create(Connection, SenderOptions, ReceiverOptions)
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
Promise<RequestResponseLink>
Löfte
isOpen()
Anger om sessionen och avsändar- och mottagarlänkarna är öppna eller stängda.
function isOpen(): boolean
Returer
boolean
booleskt - true
- open
, . false
- closed
remove()
Tar bort avsändaren, mottagarlänken och den underliggande sessionen.
function remove()
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: 10
kommer 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).
Azure SDK for JavaScript