POMBA DMaaP
- Sharon Chisholm
- Pierre Rioux
POMBA uses DMaaP at several points in its end to end flow. DMaaP messages are used both to exchange information between components and to initiate actions. The following is a message summary
DMAAP Topic | Description | Publisher | Consumer |
pomba-audit-init | Events that trigger the entire audit process | Synapse Service | Context Aggregator |
pomba-rule-validation | Events that trigger validation engine. Message content is aggregated from all context builders | Context Aggregator | Validation Service |
pomba-audit-result | Payload with the result of audit process | Validation Service | Synapse Service or other interested parties |
pomba-audit-failure | Events with errors during audit process | Context Aggregator / Validation service | Synapse Service |
Example Messages
Note these may need to be updated to reflect more recent changes
pomba-audit-init
{
"xFromAppId": "SO",
"xTransactionId": "2309039=x",
"serviceInstanceId": "1234556-67899a",
"serviceType": "vFW",
"modelVersionId": "e9851a43-2d123bd94ff0",
"modelInvariantId": "123456-78899",
"customerId": "1234c-56789"
}pomba-rule-validation
{
"event-header": {
"entity-type": "poa-entity",
"top-entity-type": "poa-entity",
"event-type": "POA-EVENT",
"domain": "IST3S2",
"id": "07f6cf70-70f6-4d60-a68c-dc9d36750cf6",
"topic-name": "POA-RULE-VALIDATION",
"source-name": "RO",
"event-id": "aa4d22fd-b69a-4114-a901-53ac5a85729a"
},
"entity": {
"poa-event": {
"serviceType": "vFW",
"modelVersionId": "e9851a43-2d123bd94ff0",
"modelInvariantId": "123456-78899",
"customerId": "1234c-56789",
"serviceInstanceId": "1234556-67899a",
"xTransactionId": "2309039=x",
"xFromAppId": "Data-Router"
},
"context-list": {
...
}
}pomba-audit-result
{
"validationId": "f825a232-b95b-425e-8ab0-bad4b913f770",
"validationTimestamp": "20180726T130520Z",
"entityType": "poa-entity",
"resourceVersion": null,
"violations": [
...
"entityId": {
},
"entityLink": "",
"entity": {
"poa-event": {
"serviceType": "vFW",
"modelVersionId": "e9851a43-2d123bd94ff0",
"modelInvariantId": "e9851a43-2d123bd94ff0",
"customerId": "1234c-56789",
"serviceInstanceId": "1234556-67899a",
"xTransactionId": "2309039=x",
"xFromAppId": "Data-Router"
},
"context-list": {
...
}