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": {
      ...
}



  • No labels