Ressources · Intégration n8n

Intégration AMQP Sender n8nAutomatiser AMQP Sender avec n8n.

Un workflow peut parler à un bus de messages, pas seulement à une API. L'intégration AMQP Sender n8n associe un nœud d'envoi, porteur de 1 opération, et l'AMQP Trigger qui écoute une file ou un sujet. Elle s'adresse aux équipes qui font déjà tourner un broker AMQP 1.0 comme ActiveMQ.

Tester l'intégration AMQP Sender sur n8nVoir les 1 opérations

Avis vérifiés sur Trustpilot · Agence IA, automatisation & growth

Pourquoi automatiser

À quoi sert vraiment l'intégration AMQP Sender n8n ?

L'intégration AMQP Sender n8n relie un workflow à un broker de messages qui parle AMQP 1.0, le protocole ouvert derrière les systèmes de files et de routage comme ActiveMQ. Deux nœuds sont livrés avec n8n pour ça. L'AMQP Sender publie un message brut sur une file ou un sujet, une fois par item. L'AMQP Trigger démarre un workflow quand un message arrive sur la file ou le sujet qu'il écoute. Les deux partagent le même credential, le jeu d'identifiants nommé AMQP connection.

Commence par le côté émission. Un workflow récupère des relevés machine, les met en forme et passe chaque ligne à l'AMQP Sender, qui publie un message par item sur un sujet. C'est exactement la forme du template 608, qui génère des données de capteurs d'usine et les met en file en AMQP. Les consommateurs branchés derrière ne parlent jamais à n8n, ils lisent le sujet.

Deuxième forme, n8n en producteur d'un flux vivant. Le template 762 enchaîne un nœud qui va chercher la position de l'ISS et un AMQP Sender qui pousse ces coordonnées vers un sujet ActiveMQ. Même logique pour un cours, un niveau de stock ou un statut que tu récupères déjà quelque part dans un workflow.

Troisième forme, l'image miroir. L'AMQP Trigger écoute une file et chaque message devient un item que tu peux router. Ensuite, les destinations classiques prennent le relais : une ligne dans Postgres, un enregistrement dans MySQL, une ligne dans Google Sheets pour l'équipe qui lit les chiffres, ou un message dans Slack quand une décision humaine s'impose.

Un point mérite qu'on s'arrête, parce qu'il change la façon de cadrer un projet. Le credential AMQP ouvre une connexion vers ton broker. Ce n'est pas une API HTTP, et la différence est réelle : avec une application HTTP, tout ce que le nœud laisse de côté t'envoie vers un nœud de requête générique. Ici, il n'y a rien de générique sur quoi se rabattre. L'AMQP Sender et l'AMQP Trigger forment la surface, et ce qu'ils exposent définit ce qu'un workflow peut faire.

Deux choses encore avant de construire. Le broker reste à ta charge : n8n attend un broker compatible AMQP 1.0, et ActiveMQ est l'exemple que sa documentation cite. Et n8n ne publie aucun mécanisme de livraison pour l'AMQP Trigger, alors appuie-toi sur la règle qui tient : le workflow doit être actif pour que le trigger écoute. Si tu compares les plateformes pour ce genre de tuyauterie, l'Avis n8n détaille la question de l'auto-hébergement.

Connexion

Comment connecter n8n à ton broker AMQP ?

  1. 01

    Faire tourner un broker AMQP 1.0

    C'est le prérequis que la documentation n8n annonce sans détour : installer un broker de messages compatible AMQP 1.0. ActiveMQ est l'exemple qu'elle donne, et la liste AMQP Products couvre les autres options. Les deux nœuds dialoguent avec ce broker, donc rien ne fonctionne tant qu'il n'est pas démarré et joignable depuis la machine qui exécute n8n. Sur n8n Cloud, joignable veut dire joignable depuis internet.

  2. 02

    Créer le credential AMQP

    Dans n8n, ouvre le menu Credentials et choisis AMQP connection, la seule méthode d'authentification acceptée par ces nœuds. Quatre valeurs sont demandées. Hostname, l'adresse de ton broker de messages. Port, le numéro de port que la connexion doit utiliser. User, le nom de l'utilisateur avec lequel établir la connexion, et Password, son mot de passe. Sur ActiveMQ, la valeur par défaut documentée pour les deux est admin.

  3. 03

    Choisir le transport et réutiliser le credential

    Transport Type est facultatif et accepte tcp ou tls, rien d'autre. Renseigne-le quand ton broker attend un transport explicite, laisse-le vide sinon. Un credential se crée une fois et se réutilise partout : ouvre l'AMQP Sender ou l'AMQP Trigger, sélectionne-le dans la liste déroulante, les deux nœuds sont authentifiés. Enregistre avant de quitter le formulaire.

Déclencheurs

Qu'est-ce qui démarre le workflow côté écoute ?

AMQP Trigger est le nœud qui démarre un workflow quand quelque chose se passe dans AMQP Sender. Tu actives le workflow et chaque événement reçu devient une exécution.

Ce que tu vois dans n8n

Notes de configuration

01Set up the AMQP TriggerL'AMQP Trigger s'abonne à une file ou à un sujet de ton broker et démarre le workflow quand un message y arrive. Le nœud est en version 1 et prend le même credential AMQP que l'émetteur. n8n ne documente aucun mécanisme de livraison le concernant, donc la règle sur laquelle construire est opérationnelle : le workflow doit être actif pour que le trigger écoute.

L'AMQP Trigger s'abonne à une file ou à un sujet de ton broker et démarre le workflow quand un message y arrive. Le nœud est en version 1 et prend le même credential AMQP que l'émetteur. n8n ne documente aucun mécanisme de livraison le concernant, donc la règle sur laquelle construire est opérationnelle : le workflow doit être actif pour que le trigger écoute.

Paramètres clés

  • Queue / Topic : le nom de la file ou du sujet à écouter, écrit comme ton broker le nomme.
  • Clientname : à laisser vide pour les abonnements à un sujet non durables ou pour les files.
  • Subscription : même consigne, vide pour les abonnements non durables ou les files.
  • Container ID : transmis au backend RHEA comme container_id.
Quand l'utiliser
dès qu'un autre système publie déjà sur ton broker et que tu veux faire réagir n8n à ces messages, plutôt que de demander à ce système d'appeler n8n.
02Shape the incoming messageUn message qui sort d'un broker n'est pas encore un item JSON propre. Trois options du trigger décident de ce que reçoit le nœud suivant, et bien les régler évite une pile d'étapes de nettoyage derrière.

Un message qui sort d'un broker n'est pas encore un item JSON propre. Trois options du trigger décident de ce que reçoit le nœud suivant, et bien les régler évite une pile d'étapes de nettoyage derrière.

Paramètres clés

  • JSON Parse Body : parse le corps du message en objet, pour que les nœuds suivants lisent des champs et pas une chaîne de caractères.
  • Only Body : ne renvoie que la propriété body et laisse tomber le reste de l'enveloppe du message.
  • Convert Body To String : convertit le contenu JSON du corps d'un tableau d'octets vers une chaîne, ce que la documentation signale comme nécessaire pour Azure Service Bus.
Cas d'usage
une file d'événements de commande alimente une table. Active JSON Parse Body et Only Body, l'item arrive avec des champs nommés prêts à mapper sur des colonnes, sans nœud de transformation intermédiaire.
03Tune throughput and reconnectionLes options restantes règlent la quantité prise à chaque fois et le comportement quand le lien avec le broker tombe. Sur une file chargée, ça compte, et ça se règle avant la mise en production plutôt qu'après.

Les options restantes règlent la quantité prise à chaque fois et le comportement quand le lien avec le broker tombe. Sur une file chargée, ça compte, et ça se règle avant la mise en production plutôt qu'après.

Paramètres clés

  • Messages per Cicle : le nombre de messages tirés du bus à chaque cycle.
  • Sleep Time : les millisecondes de pause après chaque cycle.
  • Parallel Processing : traite les messages en parallèle plutôt qu'à la suite.
  • Reconnect : reconnecte automatiquement en cas de coupure, avec Reconnect Limit qui plafonne le nombre de tentatives.
Quand l'utiliser
sur une file qui se remplit plus vite que le workflow ne la vide, monte le lot et garde Reconnect actif pour qu'un redémarrage du broker ne laisse pas le trigger muet.
Actions

Ce que le nœud AMQP Sender sait faire

Le nœud AMQP Sender expose une opération. Pour chacune : le nœud tel que tu le configures dans n8n, les champs obligatoires, et nos notes de terrain.

01

Sends a raw-message via AMQP 1.0, executed once per item

execute

Ce que tu vois dans n8n

Notes & cas d'usage

L'unique opération prend l'item courant et le publie comme message brut sur ton broker, une fois par item.

Paramètres clés

  • Queue / Topic : la destination sur le broker, écrite comme ton fournisseur l'attend, par exemple topic://sourcename.something.
  • Headers : des paramètres d'en-tête en JSON plat, envoyés comme application_properties dans les métadonnées du message.
  • Send Property : la seule propriété à envoyer ; vide, c'est l'item entier qui part.
  • Data as Object : envoie la donnée sous forme d'objet.
Cas d'usage
pointe Queue / Topic vers ta destination, par exemple topic://sourcename.something, et laisse Send Property vide pour que l'item entier parte comme message. C'est exactement ce que fait le template 608 pour transformer chaque relevé de capteur en un message sur le sujet.
Besoin d'aide

Besoin d'aide pour automatiser AMQP Sender avec n8n ?

L'équipe te répond directement.

Chaque message est lu par une personne.

FAQ

AMQP Sender et n8n, les réponses

01L'intégration AMQP Sender n8n est-elle gratuite ?
Oui côté n8n. L'AMQP Sender et l'AMQP Trigger sont livrés avec n8n, il n'y a donc rien à installer et aucun coût supplémentaire pour les nœuds eux-mêmes. C'est vrai sur n8n Cloud, l'offre hébergée par n8n, comme sur une instance auto-hébergée en Community Edition, sous licence Sustainable Use. Un workflow se comporte pareil dans les deux cas. Ce qui sort de cette réponse, c'est le broker : AMQP suppose un broker de messages compatible AMQP 1.0, et ce qu'il te coûte à faire tourner ou à souscrire est une question séparée de n8n.
02Quels identifiants demande le nœud AMQP Sender ?
Un seul type de credential, appelé AMQP connection, partagé par l'émetteur et le trigger. Il réclame un Hostname, l'adresse de ton broker de messages, un Port, le numéro de port que la connexion doit utiliser, un User, le nom de l'utilisateur avec lequel établir la connexion, et le Password de cet utilisateur. ActiveMQ documente admin comme valeur par défaut pour User et pour Password. Transport Type reste facultatif et accepte tcp ou tls. Le credential se crée une fois dans le menu Credentials et se choisit ensuite dans la liste déroulante de chaque workflow concerné.
03Quelles sont les limites des nœuds AMQP dans n8n ?
Le catalogue est volontairement étroit. L'AMQP Sender porte 1 opération, sur une ressource unique et synthétique, et l'AMQP Trigger écoute sans liste d'événements à cocher. Le point le plus structurant est ailleurs : le credential ouvre une connexion vers ton broker et non une API HTTP, donc l'échappatoire habituelle ne s'applique pas ici. Sur une application HTTP, tu te rabattrais sur un nœud de requête générique, et il n'existe pas d'équivalent pour une connexion à un broker. Les deux nœuds AMQP sont la surface disponible, et faire tourner le broker AMQP 1.0 reste à ta charge.
04L'AMQP Trigger réagit-il en temps réel ?
Rien dans le catalogue n8n ne permet de l'affirmer. L'AMQP Trigger ne déclare aucun mécanisme de livraison, ni webhook, c'est-à-dire une URL qu'un système extérieur appelle, ni polling, c'est-à-dire une vérification planifiée. Toute promesse de délai serait inventée. Ce qui est documenté suffit pour travailler. Le nœud écoute des messages AMQP 1.0 sur la file ou le sujet indiqué dans Queue / Topic, le workflow doit être actif pour qu'il écoute, et deux options décrivent le rythme : Messages per Cicle fixe le nombre de messages tirés du bus à chaque cycle, Sleep Time fixe les millisecondes de pause après chaque cycle.
05n8n ou Make pour un broker AMQP ?
Quatre critères tranchent, et aucun outil ne les gagne tous. L'hébergement d'abord : n8n tourne sur tes propres serveurs via Docker ou npm, ou sur n8n Cloud, quand Make n'existe qu'en hébergé. La maîtrise des données en découle, puisqu'un n8n auto-hébergé garde les messages dans ton réseau, ce qui pèse quand la file transporte des données de production. Le modèle de coût ensuite : Make facture à l'opération, et une file chargée change l'arithmétique. La logique visuelle enfin, affaire d'habitude plus que de capacité. Teste les deux sur un petit workflow avant d'y engager un broker.
Hack'celeration Lab

Reçois nos tips intégration chaque semaine.

Pas de spam. Désinscription à tout moment.

Même plateforme

Autres docs utiles sur ce stack.

Voir toutes les intégrations