INTEGRACIÓN RABBITMQ n8n: AUTOMATIZAR RABBITMQ CON N8N

Esta acción te permite publicar mensajes directamente en una queue o un exchange de RabbitMQ desde tu workflow n8n. Es la acción fundamental para alimentar tu arquitectura de mensajería con datos provenientes de otras aplicaciones conectadas en n8n. Perfecta para arquitecturas event-driven, microservicios, y pipelines de procesamiento asíncrono.

Parámetros clave:

• Credential to connect with: Credencial RabbitMQ requerida (dropdown) que selecciona la cuenta configurada previamente.
• Operation: Campo requerido (dropdown) que define la acción. Aquí está fijado en "Send a Message to RabbitMQ".
• Mode: Dropdown requerido que determina si el mensaje se enviará a una Queue (cola directa) o un Exchange (sistema de routing). Incluye opciones "Fixed" y "Expression" para valores estáticos o dinámicos.
• Queue / Topic: Campo de texto requerido donde especificas el nombre exacto de la queue o el exchange de destino (por ejemplo, "queue-name").
• Send Input Data: Interruptor on/off que, cuando está activado, envía automáticamente los datos de entrada del paso anterior como payload del mensaje. Si está desactivado, deberías definir un payload personalizado.
• Options: Sección que permite añadir propiedades adicionales como routing keys, headers personalizados, o configuración de durabilidad de mensajes.

Casos de uso típicos:

• Publicar eventos de negocio (pedidos, inscripciones, transacciones) en una queue RabbitMQ cuando se recibe un webhook de tu aplicación web.
• Alimentar un sistema de procesamiento asíncrono enviando datos desde una base de datos Supabase hacia RabbitMQ cada hora.
• Orquestar microservicios publicando comandos o eventos en exchanges con routing keys específicos según condiciones lógicas en n8n.

Esta acción es ideal cuando necesitas desacoplar sistemas, implementar patrones publisher-subscriber, o crear pipelines de datos robustos que transiten por RabbitMQ antes de llegar a su destino final.

Esta acción elimina un mensaje específico de una queue RabbitMQ, típicamente después de que haya sido procesado exitosamente por tu workflow. Es esencial para gestionar el ciclo de vida de mensajes y evitar el procesamiento duplicado en arquitecturas que requieren confirmación manual de tratamiento.

Parámetros clave:

• Credential to connect with: Credencial RabbitMQ requerida (dropdown) para autenticar la conexión.
• Operation: Campo requerido (dropdown) fijado en "Delete From Queue" para eliminar mensajes.
• Exchange: Campo de texto requerido que especifica el nombre del exchange (por ejemplo, "exchange-name").
• Type: Dropdown requerido que define el tipo de exchange. En el ejemplo, "Fanout" está seleccionado, lo que significa que el exchange difunde todos los mensajes recibidos a todas las queues conectadas.
• Routing Key: Campo de texto requerido donde especificas la routing key del mensaje a eliminar (por ejemplo, "routing-key").

Casos de uso típicos:

• Eliminar mensajes de una queue después de haberlos procesado y almacenado en una base de datos como Airtable, confirmando así su tratamiento exitoso.
• Limpiar queues de mensajes obsoletos o que han fallado después de X intentos de procesamiento.

Esta acción debe utilizarse típicamente en workflows que consumen mensajes de RabbitMQ vía un Trigger RabbitMQ (cuando esté disponible) o cuando necesitas gestionar manualmente el acknowledgement de mensajes en arquitecturas complejas.