Payam Message QueueIntegraciónZS022000

Plataforma de colas de mensajes

Payam es la plataforma de colas de mensajes de Niadad que transporta mensajes entre servicios de forma fiable, con ordenación, reintentos y gestión de mensajes fallidos.

Familia
Integración
Propietario
Niadad
Estado
En desarrollo

Problema

Cuando los servicios dependen unos de otros de forma directa y síncrona, un servicio lento o con fallos arrastra al resto, y las solicitudes se pierden en los picos de carga. Los trabajos de larga duración, como la facturación o las notificaciones, mantienen en espera a los canales de cara al usuario.

Visión general de la plataforma

Payam es la capa de desacoplamiento entre servicios de Niadad: un productor deposita un mensaje en una cola y un consumidor lo recoge a su propio ritmo. La entrega garantizada, el orden por cola, los reintentos con espera progresiva y las colas de mensajes fallidos hacen que ningún trabajo se pierda en silencio y que la carga se absorba de forma controlada.

Capacidades clave

Entrega garantizada

Los mensajes se conservan de forma persistente hasta que el consumidor confirma su recepción.

Ordenación y particionado

Mantiene el orden por cola o clave mientras reparte la carga entre los consumidores.

Reintentos y cola de mensajes fallidos

Los mensajes fallidos se reenvían con intervalos de espera crecientes y, finalmente, se apartan para su inspección.

Programación y retardo

Los mensajes pueden entregarse a una hora determinada o tras un retardo definido.

Multiinquilino y seguridad

Las colas se aíslan mediante espacios de nombres, permisos y cifrado en tránsito.

Monitorización de colas

Registra la profundidad de las colas, el retraso de los consumidores y la tasa de errores y los muestra en Bidar.

Arquitectura

01

Bróker de mensajes con almacenamiento persistente

02

Modelo de colas, temas y suscripciones

03

Política de reintentos y colas de mensajes fallidos

04

Capa de autorización y cifrado

05

Bibliotecas cliente y protocolos estándar

06

Métricas y alertas de colas

Integraciones

Jarian (eventos y streaming)
Sepehr (patrones de solicitudes asíncronas)
Bidar (monitorización de colas)
Shanasa (identidad de servicios)
Protocolos AMQP y MQTT
Core banking y sistemas internos

Casos de uso

Procesamiento asíncrono de transacciones bancarias
Envío de notificaciones y SMS
Facturación e informes de larga duración
Absorción de picos de carga
Integración de sistemas heredados

Construyamos juntos.

Si su organización, banco o sector está preparado para convertir los datos en decisiones, inicie la conversación aquí.