Pub/sub - endpoints - AMQP

Lecture prérequise : Architecture Pub/sub.

Vue d'ensemble

Les messages publiés sur les sujets Zato peuvent être automatiquement transmis aux courtiers AMQP.

Tout d'abord, une définition AMQP et une connexion sortante doivent être créées dans Dashboard. Ensuite, des endpoints pub/sub doivent être créés pour accorder aux connexions AMQP sortantes l'accès à des sujets ou des modèles spécifiques. Ensuite, un abonnement combinant à la fois l'endpoint et la connexion sortante peut être créé.

Ensuite, chaque fois qu'un message est publié sur l'un des sujets auxquels les endpoints AMQP sont abonnés, il sera transmis au courtier AMQP distant. Il est également possible d'utiliser des échanges, des clés de routage, un encodage, un type de contenu et d'autres métadonnées spécifiques.

Actuellement, les points d'extrémité AMQP peuvent agir en tant qu'abonnés aux sujets. Dans les futures versions de Zato, des moyens seront ajoutés pour permettre aux points d'extrémité AMQP d'agir comme des éditeurs de sujets, c'est-à-dire que les messages envoyés par les courtiers AMQP seront automatiquement publiés dans les sujets Zato.

Endpoints

En-tête Notes
Nom Nom du endpoint
Type AMQP
Role Actuellement, doit être toujours Abonné
Topics allowed Une liste de modèles pour les sujets auxquels ce endpoint sera autorisé à s'abonner.

Subscriptions

En-tête Notes
Type AMQP
Delivery server À partir de quel serveur les messages seront envoyés aux brokers AMQP.
Endpoint Un endpoint pub/sub déjà existant au nom duquel les messages seront envoyés aux courtiers AMQP.
Delivery method Doit être toujours notifié
Delivery batch size Combien de messages au maximum peuvent être envoyés en un seul lot aux brokers AMQP
List required Les messages doivent-ils toujours être enveloppés dans un élément de liste, même s'il n'y a qu'un seul message
Delivery max retries Combien de fois faut-il réessayer de livrer un message jusqu'à ce qu'il soit considéré comme non livrable
Sleep on socket error Combien de secondes à attendre après la réception d'une erreur de socket au niveau TCP dans la communication avec les courtiers AMQP
Sleep on error error Comme ci-dessus, mais pour les erreurs non liées au socket
Topics Une liste de sujets auxquels s'abonner - seuls les sujets pour lesquels l'endpoint choisi a des droits d'abonnement sont affichés.
AMQP outconn Une connexion AMQP sortante pour délivrer des messages
AMQP exchange échange AMQP pour délivrer des messages
AMQP routing key Clé de routage AMQP à utiliser pendant la livraison

Sujets connexes