FFA

Description

Implement Change Data Capture (CDC) for Cusres information related to Air Import Manifests from the Oracle database and publish the captured events to ActiveMQ for downstream processing.

This task aims to ensure that any create/update (and if applicable delete) operations on Cusres records are reliably detected and propagated in near real-time.

Scope

Monitor relevant Oracle tables/views containing Cusres data for Air Import Manifests.

Capture CDC events for:

Insert

Update

(Optional) Delete — confirm business requirement

Transform captured data into a standard CDC event payload.

Publish events to ActiveMQ using the existing Common-CDC framework.

Ensure proper transaction handling and ordering where applicable.

Technical Requirements

Source Database: Oracle

CDC Mechanism: Common-CDC (existing pattern / framework)

Messaging Broker: ActiveMQ

Event Format:

Include operation type (INSERT / UPDATE / DELETE)

Include primary identifiers (e.g. Manifest ID, Cusres reference)

Include timestamp and source metadata

Error handling and retry mechanism for message publishing failures

Logging and monitoring for CDC events

Acceptance Criteria

Cusres data changes for Air Import Manifests are captured from Oracle.

CDC events are successfully published to ActiveMQ.

Events contain accurate and complete Cusres information.

No data loss during high-volume updates.

Failures are logged and retried according to CDC standards.

Dependencies / Notes

Confirm exact Oracle tables and columns involved.

Confirm ActiveMQ topic/queue naming convention.

Validate whether DELETE events are required.

Coordinate with consumers to validate payload structure.