AMQP / RabbitMQ

Restorm toteuttaa AMQP 0-9-1 -protokollan, jota RabbitMQ käyttää.

Napsauta projektipuuta hiiren oikealla painikkeella ▸ Lisää ▸ AMQP-pyyntö.

AMQP-välilehti Julkaise-tilassa: välittäjän URL, virtuaalipalvelin, tunnistetiedot, exchange, routing key ja JSON-hyötykuorma

Yhteinen kokoonpano

Kenttä	Tehtävä
URL	`amqp://` tai `amqps://`
Vhost	Virtuaalipalvelin; oletuksena `/`
Käyttäjätunnus / Salasana	Salasana hyväksyy Salaisuus-tyyppisen arvon
Tila	`publish`, `subscribe` tai `browse`

Tila `publish`

Kenttä	Tehtävä
Exchange	Exchangen nimi; tyhjä merkkijono tarkoittaa oletus-exchangea
Routing key	Reititysavain, joka hyväksyy `{{variables}}`
Hyötykuorma	Viestin sisältö

Tila `subscribe`

Kenttä	Tehtävä
Jono	Kulutettava jono
Automaattinen kuittaus	Käytössä oletuksena; poista käytöstä, jos haluat tarkkailla uudelleentoimituksen käyttäytymistä
Prefetch	Suurin määrä kuittaamattomia viestejä lennossa

Tila `browse`

Tarkastelee jonon sisältöä kuluttamatta sitä: Restorm poimii sieltä rajatun määrän viestejä (oletuksena 50) ja palauttaa ne paikoilleen.

Tämä on juuri se tila, jota tarvitaan vastaamaan kysymykseen ”mitä tässä jonossa on?” järjestelmää häiritsemättä. Se on käytettävissä pyyntövälilehdellä; toisin kuin kahdella muulla tilalla, sillä ei ole omaa skenaariotoimintoa.

Skenaariossa

AMQP-yhteys (kuluttaa jonoa subscribe-tilassa ja lähettää yhden tapahtuman viestiä kohti), AMQP-julkaisu (julkaisee pyynnön exchangeen ja routing key -avaimelle) ja Sulje AMQP-yhteys. Katso Yhteydet ja virrat.

Koodinpätkät

Kahdeksan kohdetta: JavaScript (amqplib, julkaisuun, kulutukseen ja tarkasteluun), Python (pika), amqp-publish ja amqp-consume (amqp-tools) sekä rabbitmqadmin.