Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.datris.ai/llms.txt

Use this file to discover all available pages before exploring further.

The ActiveMQ destination writes messages to an ActiveMQ queue.

Message Format

The payload format depends on the source schema:
  • Structured data — When the schema contains regular typed columns, each row is serialized as a JSON object and sent as a text message.
  • JSON or XML — When the schema contains a single _json or _xml field, the raw string value is sent directly as the message body without additional wrapping.

Configuration Example

{
  "name": "orders_activemq",
  "source": { "..." : "..." },
  "destination": {
    "activeMQ": {
      "queueName": "orders.inbound"
    }
  }
}
ActiveMQ connection credentials are configured globally in application.yaml via secrets.activeMQSecretName. See Configuration Reference for Vault secret format.

Field Reference

FieldRequiredDefaultDescription
queueNameyesTarget queue name

Completion Notification

A pipeline notification is published to ActiveMQ on completion. See Notifications for details.