Skip to content

[Feat] Implement Post-Trade Event Processing using RocketMQ #7

@HminiL

Description

@HminiL

Is your feature request related to a problem? Please describe.

The current synchronous processing of post-trade operations (trade record storage, user notifications, etc.) presents the following issues:

  • Increased trade processing time
  • Post-processing failures affecting the trade process
  • High coupling between systems
  • Limited scalability

Describe the solution you'd like

Build event-driven system using RocketMQ for post-trade processing:

  1. Core Features
  • Publish trade events to RocketMQ
  • Store trade records in DB (Consumer 1)
  • Send user notifications (Consumer 2)
  1. Key Requirements
  • Asynchronous processing
  • Error handling & retries
  • Basic monitoring

Describe alternatives you've considered

  • Synchronous processing: Simple but slower
  • Kafka: More complex, higher throughput
  • RabbitMQ: Simpler, lower throughput

Additional context

  • Tech Stack: Spring Boot, RocketMQ
  • Target Latency: < 1 second
  • Implementation Priority: High

Sub-issues

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions