Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

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 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

Code Block
collapsetrue
{
  "xFromAppId": "SO",
  "xTransactionId": "2309039=x",
  "serviceInstanceId": "1234556-67899a",
  "serviceType": "vFW",
  "modelVersionId": "e9851a43-2d123bd94ff0",
  "modelInvariantId": "123456-78899",
  "customerId": "1234c-56789"
}

pomba-rule-validation

Code Block
collapsetrue
{
  "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

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