ABB: Message Queueing

Dienstbeschrijving

Message Queueing Dienst

Als onderdeel van RWS infrastructuur biedt het Integratie Platform met de Message Queueing Dienst een centraal beheerde oplossing voor het asynchroon uitwisselen van berichten tussen systemen en applicaties binnen Rijkswaterstaat. Deze uitwisseling gebeurt middels API’s. De dienst stelt gebruikers in staat eenvoudig berichten publiceren en consumeren via gestandaardiseerde API's.

Het Integratie Platform biedt met deze dienst:

• Ondersteuning voor messaging patterns: zoals pub/sub, queueing, fan-out, en dead-letter queues.
• Beveiliging: TLS-encryptie, authenticatie via tokens of certificaten, en toegangsbeheer per queue/topic.
• Schaalbaarheid en beschikbaarheid: clustering, load balancing, en high availability ondersteuning.
• Monitoring en logging: real-time inzicht in message throughput, latency, en foutmeldingen.
• Integratiecapaciteiten: API’s en connectoren voor gangbare programmeertalen en platforms.
• Berichtretentie en replay: mogelijkheid om berichten tijdelijk op te slaan en opnieuw af te leveren.
• Compliance en governance: audit trails, role-based access control, en ondersteuning voor interne policies.

Kostenmodel
Om de continuïteit en kwaliteit van deze dienst te waarborgen, hanteren we een pay-per-API model. Dit betekent dat per ontsloten API een vast bedrag wordt gerekend, waarmee we de infrastructuur, support en doorontwikkeling financieren. 

Functionele Specificaties

Ondersteuning voor messaging patterns:

• pub/sub
• queueing
• dead-letter queues

Beveiliging:

• TLS-encryptie
• authenticatie via OAuth tokens of certificaten
• toegangsbeheer per queue/topic

Schaalbaarheid en beschikbaarheid:

• clustering; drie instances met een gelijk gesyncte queue
• load balancing; over drie instances de workload verdeeld
• high availability; blijft actief bij uitschakeling van een instance

Monitoring en logging:

• real-time inzicht in message throughput
• Low latency zichtbaarheid
• Foutmeldingen te zien in monitoring

Integratiecapaciteiten:

• API’s voor gangbare programmeertalen en platforms
• connectoren voor gangbare programmeertalen en platforms

Berichtretentie en replay:

• mogelijkheid om berichten tijdelijk op te slaan en opnieuw af te leveren

Compliance en governance:

• audit trails
• role-based access control via RWS SAML (SSO)
• ondersteuning voor policies

Roadmaps

https://samenwerken.sp01.intranet.rws.nl/sites/vpr0000641/SitePages/Roadmap-Integratie.aspx 

Landingslocaties

De landingslocatie van de Managed Queue bevindt zich in het Rijkswaterstaat datacenter DC1.5 Intern en DC1.0 DMZ, AM2 en AM4.

Beschikbare SBBs 

RabbitMQ

Koppelvlakken

Interfaces en afhankelijkheden tussen verschillende architectuurelementen. Dit zijn bijvoorbeeld de protocollen die kunnen worden gebruikt door andere bouwblokken die gebruik maken van het ABB.

Afhankelijkheden

Unsupported Confluence link> is afhankelijk van > ABB: API Runtime environment

EIRA Koppeling

Dit bouwblok is gekoppeld binnen de EIRA aan: Distributing File System. PaaS, Streaming service

Een overzicht van alle relevante EIRA bouwblokken staan hier: EIRA Technology & Physical