Incoming Event Flows

For an incoming event, the following sequence of information flow takes place:

  1. External System will send the un-curated Insert/Update/Delete/Query/SubmitMergeRequest request messages into Kafka topic(s) specific for un-curated request data.
  2. UCM subscribes to such Kafka topics(s) and will pick up the request messages for UCM processing.
  3. UCM will publish the response messages to Kafka topic(s) and optional partition(s) specific for curated response data.

The diagram below illustrates more details of the information flow for Insert/Update/Delete/Query scenarios:

The surrounding text describes the information flow for the incoming events shown in the graphic.
  1. UCM subscribes to Kafka Topic(s) for un-curated request data, and request message posted to Kafka Topic triggers business service UCM Event Handler method ProcessEvent.
  2. The business service UCM Event Handler method ProcessEvent gets the Integration Object name from the request message, looks up the corresponding UCM workflow name in business service UCM Event Handler User Properties, invokes the workflow, and get the response message.
  3. The business service UCM Event Handler method ProcessEvent then looks up the Kafka Topic name and optional Partition(s) for curated response data in the business service UCM Event Handler User Properties, and invokes business service Event Handler method SendEvent with Topic name, Partition(s) and response message.
  4. The business service Event Handler method SendEvent publishes the response message to the Kafka Topic and Partition(s).

The diagram below illustrates more details of the information flow for SubmitMergeRequest scenario:

The surrounding text describes the information flow for the incoming events shown in the graphic.
  1. UCM subscribes to Kafka Topic(s) for SubmitMergeRequest request data, and request message posted to Kafka Topic triggers business service UCM Event Handler method ProcessEvent.
  2. The business service UCM Event Handler method ProcessEvent gets the Object Type from the request message, invokes the business service UCM Merge Service method SubmitMergeRequest, and get the response message.
  3. The business service UCM Event Handler method ProcessEvent then looks up the Kafka Topic name and optional Partition(s) for SubmitMergeRequest response data in the business service UCM Event Handler User Properties, and invokes business service Event Handler method SendEvent with Topic name, Partition(s) and response message.
  4. The business service Event Handler method SendEvent publishes the response message to the Kafka Topic and Partition(s).