Payam Message QueueIntegrazioneZS022000

Piattaforma di code di messaggi

Payam è la piattaforma di code di messaggi di Niadad che trasferisce i messaggi tra i servizi in modo affidabile, con ordinamento, tentativi ripetuti e gestione delle dead-letter.

Famiglia
Integrazione
Titolare
Niadad
Stato
In sviluppo

Problema

Quando i servizi dipendono l'uno dall'altro in modo diretto e sincrono, un servizio lento o guasto trascina con sé gli altri e le richieste vanno perse nei picchi di carico. Le elaborazioni di lunga durata, come fatturazione o notifiche, lasciano in attesa i canali rivolti agli utenti.

Panoramica della piattaforma

Payam è il livello di disaccoppiamento tra i servizi di Niadad: un produttore inserisce un messaggio in una coda e un consumatore lo preleva al proprio ritmo. Consegna garantita, ordinamento per coda, tentativi ripetuti con back-off e dead-letter queue fanno sì che nessuna attività vada persa silenziosamente e che il carico venga assorbito in modo controllato.

Capacità chiave

Consegna garantita

I messaggi vengono conservati in modo persistente finché il consumatore non ne conferma la ricezione.

Ordinamento e partizionamento

Mantiene l'ordine per coda o per chiave distribuendo il carico tra i consumatori.

Tentativi ripetuti e dead-letter queue

I messaggi non recapitati vengono riconsegnati con back-off crescente e infine messi da parte per l'analisi.

Pianificazione e ritardo

I messaggi possono essere consegnati a un orario stabilito o dopo un ritardo definito.

Multi-tenancy e sicurezza

Le code sono isolate tramite namespace, autorizzazioni e crittografia in transito.

Monitoraggio delle code

Registra la profondità delle code, il ritardo dei consumatori e il tasso di errore e li rende visibili in Bidar.

Architettura

01

Message broker con archiviazione persistente

02

Modello di code, topic e sottoscrizioni

03

Policy di retry e dead-letter queue

04

Livello di autorizzazione e crittografia

05

Librerie client e protocolli standard

06

Metriche e allarmi delle code

Integrazioni

Jarian (eventi e streaming)
Sepehr (pattern di richiesta asincroni)
Bidar (monitoraggio delle code)
Shanasa (identità dei servizi)
Protocolli AMQP e MQTT
Core banking e sistemi interni

Casi d'uso

Elaborazione asincrona delle transazioni bancarie
Invio di notifiche e SMS
Fatturazione e report di lunga elaborazione
Assorbimento dei picchi di carico
Integrazione dei sistemi legacy

Costruiamo insieme.

Se la vostra organizzazione, banca o settore è pronto a trasformare i dati in decisioni, avviate qui la conversazione.