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-message
{
"xFromAppId": "SO",
"xTransactionId": "2309039=x",
"serviceInstanceId": "1234556-67899a",
"serviceType": "vFW",
"modelVersionId": "e9851a43-2d123bd94ff0",
"modelInvariantId": "123456-78899",
"customerId": "1234c-56789"
}
pomba-rule-validation-message
{
"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-message
{
"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": {
...
}