Forwarded RabbitMQ Message Envelope
All client messages are published in this body format:
{
"action": "string",
"data": {}
}
Header / Properties Model
| Field | Type | Source | Description |
|---|---|---|---|
headers.timestamp | string | generated in publisher | Unix epoch in milliseconds as string. |
headers.msg_type | int | set per Forwarder method | Message category id used by consumers. |
correlation_id | string | null | optional, propagated from handler context when provided | Correlates downstream processing. |
content_type | string | constant | Always application/json. |
delivery_mode | int | constant | Persistent message delivery. |
expiration | int | constant | 44000 ms TTL. |
Notes
f_idis not a fixed header field; it is insidedatawhen present in action payload.- Queue selection is action-dependent (
prematch_queuevslive_queue).