Payam Message QueueIntegrationZS022000

Message-Queue-Plattform

Payam ist die Message-Queue-Plattform von Niadad, die Nachrichten zuverlässig zwischen Services überträgt, mit Reihenfolgesicherung, Wiederholungen und Dead-Letter-Behandlung.

Familie
Integration
Eigentümer
Niadad
Status
In Entwicklung

Problemstellung

Hängen Services direkt und synchron voneinander ab, reißt ein langsamer oder ausfallender Service die übrigen mit, und bei Lastspitzen gehen Anfragen verloren. Langlaufende Aufgaben wie Rechnungsstellung oder Benachrichtigungen lassen die nutzerseitigen Kanäle warten.

Plattformübersicht

Payam ist die Entkopplungsschicht von Niadad zwischen Services: Ein Produzent legt eine Nachricht in eine Queue, und ein Konsument holt sie in seinem eigenen Tempo ab. Garantierte Zustellung, Reihenfolge je Queue, Wiederholungen mit Back-off und Dead-Letter-Queues sorgen dafür, dass keine Arbeit unbemerkt verloren geht und Last kontrolliert abgefangen wird.

Kernfunktionen

Garantierte Zustellung

Nachrichten werden persistent gespeichert, bis der Konsument sie bestätigt.

Reihenfolge und Partitionierung

Wahrt die Reihenfolge je Queue oder Schlüssel und verteilt zugleich die Last auf die Konsumenten.

Wiederholungen und Dead-Letter-Queue

Fehlgeschlagene Nachrichten werden mit zunehmendem Back-off erneut zugestellt und schließlich zur Prüfung beiseitegelegt.

Zeitplanung und Verzögerung

Nachrichten können zu einem festgelegten Zeitpunkt oder nach einer definierten Verzögerung zugestellt werden.

Mandantenfähigkeit und Sicherheit

Queues werden durch Namespaces, Berechtigungen und Transportverschlüsselung voneinander isoliert.

Queue-Monitoring

Erfasst Queue-Tiefe, Consumer-Lag und Fehlerrate und macht sie in Bidar sichtbar.

Architektur

01

Message Broker mit dauerhafter Speicherung

02

Modell aus Queues, Topics und Abonnements

03

Wiederholungsrichtlinie und Dead-Letter-Queues

04

Autorisierungs- und Verschlüsselungsschicht

05

Client-Bibliotheken und Standardprotokolle

06

Queue-Metriken und -Alarme

Integrationen

Jarian (Events und Streaming)
Sepehr (asynchrone Anfragemuster)
Bidar (Queue-Monitoring)
Shanasa (Service-Identität)
AMQP- und MQTT-Protokolle
Core Banking und interne Systeme

Anwendungsfälle

Asynchrone Verarbeitung von Banktransaktionen
Versand von Benachrichtigungen und SMS
Rechnungsstellung und langlaufende Berichte
Abfangen von Lastspitzen
Integration von Altsystemen

Lassen Sie uns gemeinsam bauen.

Wenn Ihre Organisation, Ihre Bank oder Ihre Branche bereit ist, Daten in Entscheidungen zu verwandeln, beginnen Sie das Gespräch hier.