RabbitMQ messages should have the same payload structure as the Publish API endpoint.
{ "tenant_id": "<TENANT_ID>", "destination_id": "<DESTINATION_ID>", // Optional. Provide a way of routing events to a specific destination "topic": "topic.name", // Topic defined in TOPICS environment variable "eligible_for_retry": true | false, // Should event delivery be retried? Default is true. "metadata": Payload, // can be any JSON payload, "data": Payload // can be any JSON payload}