Skip to main content

Sending Messages to RabbitMQ from a Production

InterSystems IRIS becomes a RabbitMQ publisher when an interoperability production includes a business operation that uses the RabbitMQ outbound adapter. This adapter allows the business operation to send messages to a RabbitMQ exchange. You have two options when using a production as a RabbitMQ publisher: use a built-in business operation that leverages the outbound adapter or build your own business operation that uses the adapter.

Adapter Details

The RabbitMQ outbound adapter is the class EnsLib.RabbitMQ.OutboundAdapterOpens in a new tab. It includes the following settings, all of which appear in the Management Portal as settings for the business operation that uses the adapter:

  • MQHost defines the hostname or IP address for the RabbitMQ server.

  • MQPort defines the port number for communicating with RabbitMQ.

  • MQVirtualHost (optional) defines the virtual hostname for RabbitMQ.

  • Credentials defines the InterSystems credentials that correspond to the username and password of a Kafka client. For details on creating credentials, see Defining Reusable Items for Use in Settings.

For general information about building a custom business operation that uses an outbound adapter, see Defining Business Operations.

SSL/TLS Configuration

Both of the RabbitMQ adapters (inbound and outbound) accept additional settings which allow you to configure your production to connect with RabbitMQ using SSL/TLS. These settings also appear in the Management Portal as settings for the business service that uses the adapter.

For a detailed list of these settings, refer to the instructions for configuring a RabbitMQ client using the RabbitMQ API.

Send RabbitMQ Messages

The class of the messages sent by the outbound adapter to RabbitMQ is EnsLib.RabbitMQ.MessageOpens in a new tab. This class contains several properties for defining the message, including the following:

  • exchange defines the RabbitMQ exchange where the publisher is sending messages.

  • routingKey defines the routing key which the exchange will use to route the message.

  • deliveryMode defines whether the message will be treated as persistent (if the value is 2) or transient (if the value is 2).

  • contentEncoding defines the encoding of the message content (such as UTF-8).

  • encodedContent defines the content of the message, encoded as specified by contentEncoding.

For full descriptions of the message properties this message class makes available, refer to the RabbitMQ documentationOpens in a new tab.

The outbound adapter's SendMessage() method takes a EnsLib.RabbitMQ.MessageOpens in a new tab object as its sole argument, and sends that message to the RabbitMQ server. For example, a custom business operation could call the adapter’s method by including the following:

Do ..Adapter.SendMessage(pRequest)

Built-in Business Operation

Rather than building a custom business operation that uses the outbound adapter, you can simply add EnsLib.RabbitMQ.OperationOpens in a new tab to the production and define the adapter properties using the Management Portal settings. This business operation calls the adapter's SendMessage() method when it receives a request from another business host in the production. This request should contain a RabbitMQ message of type EnsLib.RabbitMQ.MessageOpens in a new tab.

For basic information about adding a business operation to a production, see Adding Business Hosts.

See Also

FeedbackOpens in a new tab