Recursos · Integración n8n

Integración RabbitMQ n8nAutomatiza RabbitMQ con n8n.

Una cola deja de ser una caja negra cuando n8n se sitúa en sus dos extremos. La integración RabbitMQ n8n son 2 operaciones de nodo, publicar un mensaje y borrar uno de una cola, más un trigger que consume una cola y lanza una ejecución por cada mensaje que llega.

Probar la integración RabbitMQ en n8nVer las 2 operaciones

Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth

Por qué automatizar

¿Qué cubre de verdad la integración RabbitMQ n8n?

RabbitMQ es un broker de mensajes: un sistema deja mensajes en una cola y otro los recoge cuando está listo para trabajar. La integración de n8n coloca un flujo de trabajo a cada lado de esa cola. El nodo RabbitMQ publica un mensaje hacia una cola o hacia un exchange, y también borra un mensaje de una cola. El RabbitMQ Trigger hace de consumidor: cada mensaje que entra en la cola se convierte en una ejecución.

El primer caso tiene que ver con el ritmo. Un flujo que recoge datos cada cierto tiempo suele ir más rápido que lo que viene después a guardarlos. Si cada resultado se publica en un topic de RabbitMQ, el segundo flujo vacía la cola a su propia velocidad y luego escribe las filas en Postgres. La biblioteca de plantillas de n8n enseña el patrón con posiciones de satélite enviadas a un topic (workflow 844).

El segundo caso es el reparto. La biblioteca de plantillas de n8n muestra eventos de alta de cliente publicados en RabbitMQ con una clave de enrutado, recogidos por un flujo consumidor que da forma al mensaje con un nodo Code y envía el aviso por Gmail (plantilla 15316). Un flujo publica, un consumidor dedicado reacciona, en vez de un único flujo que crece rama tras rama.

El tercer caso es la difusión. Un exchange de tipo fanout copia un mensaje publicado hacia todas las colas enlazadas a él. Así, un solo mensaje de pedido pagado alimenta a la vez un flujo que archiva el histórico y otro que abre una incidencia en GitHub para el equipo técnico. Publicas una vez y el broker se encarga de la copia.

Ahora los límites, sin rodeos. El nodo trae 2 operaciones y ninguna más: no lista colas, no gestiona usuarios, no lee un mensaje fuera del trigger. Además, la credencial abre una conexión AMQP contra el broker, no una API HTTP. El recurso habitual de añadir un nodo HTTP Request para tapar una operación que falta no sirve aquí. Lo que el nodo y el trigger no exponen no se hace desde n8n, se queda del lado de RabbitMQ.

Conviene decirlo claro: esto encaja en equipos que ya tienen un broker en marcha y quieren automatizar a su alrededor, no en equipos que esperan administrar RabbitMQ desde n8n. Si las colas son terreno nuevo para quien va a mantener estos flujos, el Curso n8n cubre las nociones de trigger y credencial que esta página da por sabidas, y la Reseña n8n sitúa la herramienta en su contexto.

Conexión

¿Cómo conectas n8n con un broker de RabbitMQ ?

  1. 01

    Apunta n8n al broker

    En n8n, abre el menú Credentials y crea una credencial RabbitMQ, es decir unos datos de acceso que se guardan una vez y se reutilizan. El único método admitido es la conexión de usuario. Empieza por la máquina: Hostname recibe el equipo donde corre RabbitMQ y Port el puerto que debe usar la conexión. Cada nodo RabbitMQ que añadas después ofrecerá esta credencial en su desplegable.

  2. 02

    Rellena la cuenta y el vhost

    User es la cuenta con la que entra la conexión y Password su contraseña. RabbitMQ viene con la cuenta guest, cuya contraseña por defecto es guest, y recomienda usar otro usuario en producción. Vhost espera el host virtual que debe usar la conexión, una forma de dividir un mismo broker en espacios aislados; el host virtual por defecto es /.

  3. 03

    Activa SSL si el broker lo pide

    El interruptor SSL decide si la conexión va cifrada. Al activarlo, Passwordless indica si la conexión por certificado usa el mecanismo SASL EXTERNAL o prescinde de contraseña. En ese segundo caso pega el Client Certificate y el Client Key como texto, junto con la Passphrase. En CA Certificates va el texto de los certificados de autoridad que hay que reconocer.

Disparadores

¿Qué escucha el RabbitMQ Trigger?

RabbitMQ Trigger es el nodo que arranca un workflow cuando algo ocurre en RabbitMQ. Activas el workflow y cada evento recibido se convierte en una ejecución.

Lo que ves en n8n

Notas de configuración

01Configure the RabbitMQ TriggerAquí no hay lista de eventos que marcar. El trigger consume una cola y genera una ejecución por cada mensaje que entra en ella. Guarda el flujo y actívalo: un flujo inactivo no escucha nada.

Aquí no hay lista de eventos que marcar. El trigger consume una cola y genera una ejecución por cada mensaje que entra en ella. Guarda el flujo y actívalo: un flujo inactivo no escucha nada.

Parámetros clave

  • Queue / Topic: el nombre de la cola que hay que leer, escrito tal cual existe en el broker, por ejemplo pedidos.creados.
  • Delete From Queue When: dentro de Options, marca el momento del acuse de recibo, o sea si el mensaje sale de la cola en cuanto n8n lo recibe o cuando termina la ejecución.
  • Parallel Message Processing Limit: el número máximo de ejecuciones a la vez. Con -1 no hay tope.
Cuándo usarlo
cuando otro sistema ya publica en RabbitMQ y prefieres que n8n sea el consumidor, en vez de exponerle una URL de n8n. Acusar recibo al final de la ejecución evita que un fallo haga desaparecer el mensaje sin avisar.
02Shape the messages the trigger returnsEl mensaje llega como contenido en bruto. La colección Options decide qué entrega n8n al nodo siguiente y cómo se declara la cola.

El mensaje llega como contenido en bruto. La colección Options decide qué entrega n8n al nodo siguiente y cómo se declara la cola.

Parámetros clave

  • JSON Parse Body: convierte el cuerpo en un objeto, así sus campos se usan más adelante como {{ $json.campo }} en lugar de una cadena de texto única.
  • Only Content: devuelve solo la propiedad de contenido, sin el sobre de entrega que la envuelve.
  • Content Is Binary: guarda el contenido en binario, el ajuste para mensajes que llevan un archivo y no texto.
  • Assert Queue, Durable, Exclusive, Auto Delete Queue: comprobar que la cola existe antes de leer, mantenerla tras un reinicio del broker, limitarla a esta conexión o eliminarla cuando ya no queda ningún consumidor.
  • Binding, Arguments, Headers: añadir un binding a la cola y acompañarla de argumentos o cabeceras.
Cuándo usarlo
activa JSON Parse Body y Only Content frente a un emisor que manda JSON, y deja Durable puesto en una cola que debe sobrevivir al reinicio del broker.
Acciones

¿Qué sabe hacer el nodo RabbitMQ ?

El nodo RabbitMQ expone 2 operaciones. Para cada una: el nodo tal como lo configuras en n8n, los campos obligatorios y nuestras notas de campo.

01

Send a Message to RabbitMQ

sendMessage

Lo que ves en n8n

Notas y casos de uso

Publica un mensaje en una cola o en un exchange.

Parámetros clave

  • Queue / Topic: el nombre de la cola de destino.
  • Exchange y Type: pasar por un exchange de tipo direct, topic, headers o fanout, según el reparto buscado.
  • Routing Key: la clave de enrutado con la que el exchange hace la correspondencia.
  • Send Input Data: manda el item de entrada como JSON; desactivado, escribes tú mismo el contenido en Message.
  • Alternate Exchange: dentro de Options, un exchange de reserva para los mensajes que este no logra enrutar a ninguna cola.
Casos de uso
entregar cada ficha recogida a un consumidor que la archiva, o publicar un mensaje de factura cobrada que otro flujo leerá más tarde.
02

Delete From Queue

deleteMessage

Lo que ves en n8n

Notas y casos de uso

Quita un mensaje de una cola en lugar de publicar en ella. La operación trabaja sobre una entrada que ya existe, no añade ninguna.

Parámetros clave

  • Queue / Topic: la cola sobre la que actúa la operación.
  • Exchange y Type: nombrar el exchange cuando el destino pasa por él, con las mismas opciones direct, topic, headers y fanout.
  • Routing Key: la clave de enrutado asociada al mensaje.
  • Message: el mensaje al que apunta la operación, tomado a menudo del trigger con una expresión como {{ $json.content }}.
Casos de uso
limpiar una entrada que ya se ha tratado por otra vía, o descartar un mensaje que una validación acaba de rechazar.
Necesitas ayuda

¿Necesitas ayuda para automatizar RabbitMQ con n8n?

El equipo te responde directamente.

Cada mensaje lo lee una persona.

FAQ

RabbitMQ y n8n, preguntas frecuentes

01¿La integración RabbitMQ n8n es gratuita?
Sí, por el lado de n8n. Tanto el nodo RabbitMQ como el RabbitMQ Trigger vienen incluidos con n8n: no hay nada que instalar ni ningún módulo que comprar, ya uses n8n Cloud o una instancia autoalojada en Community Edition, con su licencia Sustainable Use. Un flujo construido en una funciona igual en la otra. Lo que sí necesitas es un broker de RabbitMQ al que conectarte, que alojas y pagas tú según dónde lo pongas a correr. La credencial de n8n no te da un broker ni cambia nada en la forma en que se factura el tuyo.
02¿Qué credenciales pide el nodo RabbitMQ?
Un único tipo de credencial, la conexión de usuario, compartida por el nodo y el trigger. Pide el Hostname del broker, el Port, el User y el Password con los que entra la conexión, y el Vhost, el host virtual que debe usar, cuyo valor por defecto es una simple barra. RabbitMQ crea una cuenta guest con guest como contraseña y recomienda otro usuario en producción. Un interruptor SSL abre la variante cifrada: Passwordless, Client Certificate, Client Key, Passphrase y CA Certificates, todos pegados como texto. Se crea una vez en el menú Credentials y se reutiliza en todos los flujos.
03¿Qué límites tiene el nodo RabbitMQ en n8n?
El nodo tiene 2 operaciones: enviar un mensaje y borrar uno de una cola. El resto de la administración del broker se queda fuera de n8n: ni listado de colas, ni gestión de cuentas, ni métricas, ni purga. El trigger lee una cola cada vez, así que varias colas significan varios flujos. Lo importante: la credencial abre una conexión AMQP contra el broker, no una API HTTP, de modo que añadir un nodo HTTP Request no es el plan B habitual cuando falta una operación. Lo que no está en el nodo ni en el trigger no se hace desde n8n.
04¿El RabbitMQ Trigger reacciona en tiempo real?
Eso es justo lo que n8n no detalla para este trigger. Su documentación no describe ni cómo llega la entrega hasta n8n ni intervalo alguno, así que ninguna cifra de latencia tiene sitio en esta página. Lo que sí está documentado: el trigger escucha la cola indicada en Queue / Topic, el flujo tiene que estar activo para que esa escucha ocurra, y cada mensaje produce una ejecución. Dos ajustes de Options merecen una decisión consciente: Delete From Queue When, que fija el momento del acuse de recibo, y Parallel Message Processing Limit, que limita cuántas ejecuciones corren a la vez.
05¿n8n o Make para RabbitMQ?
Depende sobre todo de dónde viva el broker y de quién controle los datos. Make está alojado por Make, sin opción de autoalojamiento, y factura por operación: cuando una cola produce miles de mensajes al día, cada mensaje cuenta como una operación. n8n se autoaloja con Docker o npm, o se usa en n8n Cloud, y el mismo flujo funciona en ambos casos. Un broker instalado en una red privada suele ser más fácil de alcanzar desde una instancia de n8n puesta en esa misma red. Make, a cambio, ofrece una lógica visual que muchos equipos leen más rápido.
Misma plataforma

Otros docs útiles sobre este stack.

Ver todas las integraciones