AMQP 1.0 a Microsoft Azure Service Busban: kérés-válaszalapú műveletek
Ez a cikk a Microsoft Azure Service Bus kérés-/válaszalapú műveleteinek listáját határozza meg. Ezek az információk az AMQP Management 1.0-s verziójának munkatervezetén alapulnak.
Az AMQP 1.0 protokoll részletes útmutatója, amely bemutatja, hogyan valósítja meg és építi a Service Bus az OASIS AMQP műszaki specifikációját, tekintse meg az AMQP 1.0-t az Azure Service Bus és az Event Hubs protokoll útmutatójában.
Fogalmak
ServiceBusReceivedMessage / ServiceBusMessage
Egy üzenet a Service Busban, amely AMQP-üzenetre van leképezve. A leképezést a Service Bus AMQP protokoll útmutatója határozza meg.
Csatolás az entitáskezelési csomóponthoz
A dokumentumban leírt összes művelet egy kérés-válasz mintát követ, hatóköre egy entitásra terjed ki, és egy entitáskezelési csomóponthoz való csatolást igényel.
Hivatkozás létrehozása kérések küldéséhez
Létrehoz egy hivatkozást a felügyeleti csomópontra a kérések küldéséhez.
requestLink = session.attach(
role: SENDER,
target: { address: "<entity address>/$management" },
source: { address: ""<my request link unique address>" }
)
Hivatkozás létrehozása a válaszok fogadásához
Létrehoz egy hivatkozást a felügyeleti csomóponttól érkező válaszok fogadásához.
responseLink = session.attach(
role: RECEIVER,
source: { address: "<entity address>/$management" }
target: { address: "<my response link unique address>" }
)
Kérési üzenet átvitele
Egy kérésüzenet átvitele.
A tranzakciós állapot opcionálisan hozzáadható a tranzakciókat támogató műveletekhez.
requestLink.sendTransfer(
Message(
properties: {
message-id: <request id>,
reply-to: "<my response link unique address>"
},
application-properties: {
"operation" -> "<operation>",
}
),
[Optional] State = transactional-state: {
txn-id: <txn-id>
}
)
Válaszüzenet fogadása
A válaszüzenetet a válaszhivatkozásból kapja meg.
responseMessage = responseLink.receiveTransfer()
A válaszüzenet a következő formában található:
Message(
properties: {
correlation-id: <request id>
},
application-properties: {
"statusCode" -> <status code>,
"statusDescription" -> <status description>,
},
)
Service Bus-entitás címe
A Service Bus-entitásokat a következőképpen kell kezelni:
Entitástípus | Cím | Példa |
---|---|---|
feldolgozási sor | <queue_name> |
“myQueue” “site1/myQueue” |
témakör | <topic_name> |
“myTopic” “site2/page1/myQueue” |
előfizetést | <topic_name>/Subscriptions/<subscription_name> |
“myTopic/Subscriptions/MySub” |
Üzenetműveletek
Üzenetmegújítási zárolás
Az üzenet zárolásának meghosszabbítása az üzenetsoron vagy előfizetésen beállított zárolási időtartamig.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:renew-lock |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
lock-tokens |
uuid tömb | Igen | Üzenetzárolási jogkivonatok megújításához. |
Feljegyzés
A zárolási jogkivonat a delivery-tag
fogadott AMQP-üzenet tulajdonságára hivatkozik. Ha halasztott üzenetet kapott, és meg szeretné újítani a zárolását, használja az üzenet tulajdonságát lock-token
ahelyett, hogy a delivery-tag
.
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen. |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
Expirations | időbélyeg tömbje | Igen | Az üzenetzárolási jogkivonat új lejárata megfelel a kérelem zárolási jogkivonatainak. |
Betekintő üzenet
Zárolás nélkül betekinti az üzeneteket.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:peek-message |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
from-sequence-number |
hosszú | Igen | Sorszám, amelyből a bepillantás elkezdhető. |
message-count |
egész | Igen | Betekintendő üzenetek maximális száma. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – több üzenete van 204: Nincs tartalom – nincs több üzenet |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | térképek listája | Igen | Azon üzenetek listája, amelyekben minden térkép egy üzenetet jelöl. |
Az üzenetet ábrázoló térképnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | bájttömb | Igen | AMQP 1.0 vezetékes üzenet. |
Üzenet ütemezése
Üzenetek ütemezése. Ez a művelet támogatja a tranzakciót.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:schedule-message |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | térképek listája | Igen | Azon üzenetek listája, amelyekben minden térkép egy üzenetet jelöl. |
Az üzenetet ábrázoló térképnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenetazonosító | sztring | Igen | amqpMessage.Properties.MessageId sztringként |
munkamenet-azonosító | húr | Nem | amqpMessage.Properties.GroupId as string |
partíciókulcs | húr | Nem | amqpMessage.MessageAnnotations.”x-opt-partition-key" |
partíciókulcson keresztül | húr | Nem | amqpMessage.MessageAnnotations."x-opt-via-partition-key" |
üzenet | bájttömb | Igen | AMQP 1.0 vezetékes üzenet. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen. |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
sorszámok | hosszú tömb | Igen | Ütemezett üzenetek sorszáma. A sorozatszám a megszakításhoz használatos. |
Ütemezett üzenet megszakítása
Megszakítja az ütemezett üzeneteket.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:cancel-scheduled-message |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
sorszámok | hosszú tömb | Igen | A megszakítandó ütemezett üzenetek sorszáma. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen. |
statusDescription | húr | Nem | Az állapot leírása. |
Munkamenet-műveletek
Munkamenet megújítási zárolása
Az üzenet zárolásának meghosszabbítása az üzenetsoron vagy előfizetésen beállított zárolási időtartamig.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:renew-session-lock |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
munkamenet-azonosító | sztring | Igen | Munkamenet-azonosító. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – több üzenete van 204: Nincs tartalom – nincs több üzenet |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
lejárat | időbélyeg | Igen | Új lejárat. |
Munkamenet üzenetének betekintője
Zárolás nélkül betekinti a munkamenet-üzeneteket.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:peek-message |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
sorozatszámból | hosszú | Igen | Sorszám, amelyből a bepillantás elkezdhető. |
üzenetszám | egész | Igen | Betekintendő üzenetek maximális száma. |
munkamenet-azonosító | sztring | Igen | Munkamenet-azonosító. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – több üzenete van 204: Nincs tartalom – nincs több üzenet |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | térképek listája | Igen | Azon üzenetek listája, amelyekben minden térkép egy üzenetet jelöl. |
Az üzenetet ábrázoló térképnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | bájttömb | Igen | AMQP 1.0 vezetékes üzenet. |
Munkamenet állapotának beállítása
A munkamenet állapotát állítja be.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:set-session-state |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
munkamenet-azonosító | sztring | Igen | Munkamenet-azonosító. |
munkamenet-állapot | bájtok tömbje | Igen | Átlátszatlan bináris adatok. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
Munkamenet állapotának lekérése
Lekéri a munkamenet állapotát.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:get-session-state |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
munkamenet-azonosító | sztring | Igen | Munkamenet-azonosító. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
munkamenet-állapot | bájtok tömbje | Igen | Átlátszatlan bináris adatok. |
Munkamenetek számbavétele
Az üzenetkezelő entitáson lévő munkamenetek számbavétele.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:get-message-sessions |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
utolsó frissítés időpontja | időbélyeg | Igen | Szűrjön úgy, hogy csak egy adott időpont után frissített munkameneteket tartalmazzon. |
Kihagyás | egész | Igen | Több munkamenet kihagyása. |
top | egész | Igen | Munkamenetek maximális száma. |
Feljegyzés
Ha a (.NET-ben) értékre DateTime.MaxValue
van állítvaLastUpdatedTime
, az Enumerate Sessions metódus az összes munkamenetet visszaadja, függetlenül attól, hogy vannak-e állapotuk. DateTime.MaxValue
lehet, hogy a .NET nem létezik más programozási nyelvekben. Ilyen esetekben használjon olyan időbélyeget, amely megegyezik 253402300800000
a korszak ezredmásodpercével (1970. január 1., 00:00:00 GMT), amely egyenértékű DateTime.MaxValue
a .NET-ben.
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – több üzenete van 204: Nincs tartalom – nincs több üzenet |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
Kihagyás | egész | Igen | Kihagyott munkamenetek száma, ha az állapotkód 200. |
munkamenet-azonosítók | sztringek tömbje | Igen | Munkamenet-azonosítók tömbje, ha az állapotkód 200. |
Szabályműveletek
Szabály hozzáadása
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:add-rule |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
szabály neve | sztring | Igen | Szabálynév, nem beleértve az előfizetés és a témakör nevét. |
szabály leírása | térkép | Igen | A következő szakaszban megadott szabályleírás. |
A szabálymegfelelőség-leképezésnek tartalmaznia kell a következő bejegyzéseket, amelyekben az SQL-szűrő és a korrelációs szűrő kölcsönösen kizárja egymást:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
sql-filter | térkép | Igen | sql-filter , a következő szakaszban megadottak szerint. |
korrelációs szűrő | térkép | Igen | correlation-filter , a következő szakaszban megadottak szerint. |
sql-rule-action | térkép | Igen | sql-rule-action , a következő szakaszban megadottak szerint. |
Az sql-filter térképnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
Kifejezés | sztring | Igen | Sql-szűrőkifejezés. |
A korrelációs szűrő térképének tartalmaznia kell legalább az alábbi bejegyzések egyikét:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
korrelációs azonosító | húr | Nem | |
üzenetazonosító | húr | Nem | |
felhasználóként a(z) | húr | Nem | |
válasz | húr | Nem | |
label | húr | Nem | |
munkamenet-azonosító | húr | Nem | |
válasz–munkamenet-azonosító | húr | Nem | |
tartalomtípus | húr | Nem | |
tulajdonságok | térkép | Nem | Térképek a Service Busba ServiceBusMessage.Properties |
Az sql-rule-action leképezésnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
Kifejezés | sztring | Igen | Sql-műveletkifejezés. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
Szabály eltávolítása
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:remove-rule |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
szabály neve | sztring | Igen | Szabálynév, nem beleértve az előfizetés és a témakör nevét. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
Szabályok lekérése
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:enumerate-rules |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
top | egész | Igen | Az oldalon beolvasandó szabályok száma. |
Kihagyás | egész | Igen | A kihagyandó szabályok száma. Meghatározza a kezdő indexet (+1) a szabályok listájában. |
Válasz
A válaszüzenet a következő tulajdonságokat tartalmazza:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
szabályok | térképek listája | Igen | Szabályok listája. Minden szabályt térkép jelöl. |
A listában szereplő összes térképbejegyzés a következő tulajdonságokat tartalmazza:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
szabály leírása | leírt objektum | Igen | com.microsoft:rule-description az AMQP által leírt kód 0x0000013700000004 |
com.microsoft.rule-description
önmagában egy leírt lista. A következő tulajdonságokkal rendelkezik:
Index | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
0 | leírt lista | Igen | filter a következő táblázatban megadottak szerint. |
0 | leírt lista | Igen | ruleAction szakasz későbbi részében megadottak szerint. |
2 | sztring | Igen | a szabály neve. |
3 | időbélyeg | Igen | Időbélyegző. |
filter
az alábbi típusok bármelyike lehet:
Leíró neve | Leíró kód | Érték |
---|---|---|
com.microsoft:sql-filter:list |
0x000001370000006 | SQL-szűrő |
com.microsoft:correlation-filter:list |
0x000001370000009 | Korrelációs szűrő |
com.microsoft:true-filter:list |
0x000001370000007 | Igaz szűrő, amely 1=1 értéket jelöl |
com.microsoft:false-filter:list |
0x000001370000008 | Hamis szűrő, amely 1=0 értéket jelöl |
com.microsoft:sql-filter:list
egy leírt lista, amely a következőket tartalmazza:
Index | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
0 | sztring | Igen | Sql Filter-kifejezés |
0 | egész | Igen | mindig 20. Ez az egész szám az SQL-szűrő kompatibilitási szintje. Az SQL-szűrő szintaxisverzióját jelzi. |
com.microsoft:correlation-filter:list
egy leírt lista, amely a következőket tartalmazza:
Index (ha létezik) | Érték típusa | Érték tartalma |
---|---|---|
0 | húr | Korrelációs azonosító |
0 | húr | Üzenetazonosító |
2 | húr | Művelet |
3 | húr | Válasz címzettje: |
4 | húr | Címke |
5 | húr | Munkamenet-azonosító |
6 | húr | Válasz munkamenet-azonosítóra |
7 | húr | Tartalom típusa |
8 | Térkép | Alkalmazás által definiált tulajdonságok térképe |
ruleAction
az alábbi típusok bármelyike lehet:
Leíró neve | Leíró kód | Érték |
---|---|---|
com.microsoft:empty-rule-action:list |
0x0000013700000005 | Üres szabályművelet – Nincs szabályművelet |
com.microsoft:sql-rule-action:list |
0x0000013700000006 | SQL-szabályművelet |
com.microsoft:sql-rule-action:list
egy leírt lista, amely két elemet tartalmaz.
Index | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
0 | sztring | Igen | SQL-szabályművelet kifejezése |
0 | egész | Igen | mindig 20. Ez az egész szám az SQL-szűrő kompatibilitási szintje. Az SQL-szűrő szintaxisverzióját jelzi. |
Halasztott üzenetműveletek
Fogadás sorszám szerint
Halasztott üzeneteket fogad sorszám szerint.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:receive-by-sequence-number |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
sorszámok | hosszú tömb | Igen | Sorszámokat. |
vevő-rendezési mód | ubyte | Igen | A fogadó rendezési módja az AMQP core 1.0-s verzióban megadott módon. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
A válaszüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
üzenet | térképek listája | Igen | Azon üzenetek listája, ahol minden térkép egy üzenetet jelöl. |
Az üzenetet ábrázoló térképnek a következő bejegyzéseket kell tartalmaznia:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
zárolási jogkivonat | uuid | Igen | Zárolási jogkivonat, ha receiver-settle-mode 1. |
üzenet | bájttömb | Igen | AMQP 1.0 vezetékes üzenet. |
A diszpozíció állapotának frissítése
Frissítések halasztott üzenetek áthelyezési állapotát. Ez a művelet támogatja a tranzakciókat.
Kérés
A kérelemüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
művelet | sztring | Igen | com.microsoft:update-disposition |
com.microsoft:server-timeout |
uint | Nem | A műveleti kiszolgáló időtúllépése ezredmásodpercben. |
A kérelemüzenet törzsének egy amqp-value szakaszból kell állnia, amely egy térképet tartalmaz a következő bejegyzésekkel:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
disposition-status | sztring | Igen | kész Elhagyott Felfüggesztett |
zárolási jogkivonatok | uuid tömb | Igen | Üzenetzárolási jogkivonatok az elhelyezés állapotának frissítéséhez. |
deadletter-reason | húr | Nem | Akkor van beállítva, ha a diszpozíció állapota fel van függesztve. |
deadletter-description | húr | Nem | Akkor van beállítva, ha a diszpozíció állapota fel van függesztve. |
tulajdonságok módosítása | térkép | Nem | A módosítandó Service Bus-közvetített üzenettulajdonságok listája. |
Válasz
A válaszüzenetnek tartalmaznia kell a következő alkalmazástulajdonságokat:
Kulcs | Érték típusa | Kötelező | Érték tartalma |
---|---|---|---|
statusCode | egész | Igen | HTTP-válaszkód [RFC2616] 200: OK – siker, egyébként sikertelen |
statusDescription | húr | Nem | Az állapot leírása. |
Következő lépések
Ha többet szeretne megtudni az AMQP-ről és a Service Busról, látogasson el az alábbi hivatkozásokra: