Architecture

Core Components

1. Oracle AQ Publisher (PL/SQL)

• PSO_Integration_CE_API: Publishes CloudEvents to Oracle AQ
• Partitioning: Messages are distributed across partitions based on event key hash
• CloudEvent Format: Implements CloudEvents 1.0 specification with required fields

2. Cloud Event Relay (Quarkus Application)

• OracleAQListener: Main polling component with parallel partition processing
• EventProcessor: Processes message batches and creates JSON payloads

3. Remote Integration

• RemoteService: REST client interface for external API communication
• AzureTokenService: Handles OAuth token acquisition for authentication
• Nexus Event Gateway: REST Endpoint in Nexus Platform that recieves cloud events and publishes to relevant Kafka topic.