AMQP Connector
Overview
The AMQP connector publishes tag values to a message queue over AMQP (via RabbitMQ.Client), suitable for RabbitMQ or any AMQP-compatible broker including managed services such as Amazon MQ. It is a pure publisher - any tag with IOType other than In is published to the configured queue whenever its value changes; the connector does not consume/read from the queue.
Parameters
| Name | Values | Description |
|---|---|---|
| Type | AMQP | The connector type identifier. |
| Protocol | e.g. amqp, amqps | Connection URI scheme. |
| Hostname | hostname or IP | Broker address. |
| Port | integer | Broker port. |
| VHost | string | AMQP virtual host path, e.g. /. |
| Username / Password | string | Broker credentials. If either is empty, an unauthenticated URI is used instead. |
| Queue | string | Name of the queue to publish to. |
| UpdateRate | milliseconds (integer) | Present for consistency with other connectors, but this connector is event-driven (publishes on ChangeData), not polled. |
Note: never hardcode broker credentials directly in source - always supply them via Username/Password parameters.
Supported Tag Types:
| Tag Type | Address | Behaviour |
|---|---|---|
| Any standard tag | not used for publishing (queue name is connector-wide, from Parameters[QUEUE]) | Any tag with IOType other than In is published (its value, as a UTF-8 string) to the configured queue on every value change, once connected. |
Connector Methods
| Name | Arguments | Description |
|---|---|---|
| (none) | - | This connector does not currently expose any custom connector-level methods via Execute Commands. |
Addressing
Not applicable - all tags publish to the single, connector-wide queue configured via Parameters[QUEUE].
Diagnostic Codes
| Code | Type | Description |
|---|---|---|
| 1210 | Error | Failed to connect |
| 1405 | Error | Failed to publish |
| 2300 | Debug | ITag not present |
| 3100 | Info | Started |
| 3205 | Info | Connected |