Task #19364
openTask #19374: Sprint Planning for 02/02/2026 - 16/02/2026
Common-CDC: Capture Cusres Data for Air Import Manifest and Publish to ActiveMQ
25%
Description
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.
GitLab Sync Log
[{"id": "37957", "author": "Al-Shad Isaac", "hours": 2.0, "created": "2026-01-30T10:47:32.312Z", "log_date": "2026-01-30", "comment": "Imported from GitLab by @Al-Shad Isaac on 2026-01-30T10:47:32.312Z: 2h-(2.0)h spend at: 2026-01-30", "status": "active", "deleted_by": "", "redmine_entry_id": 12109}, {"id": "38030", "author": "Al-Shad Isaac", "hours": 3.0, "created": "2026-02-02T07:23:21.666Z", "log_date": "2026-02-02", "comment": "Imported from GitLab by @Al-Shad Isaac on 2026-02-02T07:23:21.666Z: 3h-(3.0)h spend at: 2026-02-02", "status": "active", "deleted_by": "", "redmine_entry_id": 12126}, {"id": "38037", "author": "Al-Shad Isaac", "hours": 3.0, "created": "2026-02-02T10:03:53.753Z", "log_date": "2026-02-02", "comment": "Imported from GitLab by @Al-Shad Isaac on 2026-02-02T10:03:53.753Z: 3h-(3.0)h spend at: 2026-02-02", "status": "active", "deleted_by": "", "redmine_entry_id": 12128}]