CloudAMQP

The Devprime platform natively supports CloudAMQP, which provides a SaaS approach to RabbitMQ, an open-source messaging software that operates on the Advanced Message Queuing Protocol (AMQP) and Streaming Text Oriented Messaging Protocol (MQTT) protocols.

CloudAMQP’s configurations follow the same model as RabbitMQ’s with a point of attention to the HostName parameter that already includes the url and credentials provided when creating the service in CloudAMQP. User/Password/Port parameters are not required

Subscribe to a queue in RabbitMQ

The JSON below demonstrates the default configuration with the RabbitMQ credentials, the exchange used, the Retry, the Fallback, the Threads and the ‘Subscribe’ option to receive events in the ‘orderevents’ queue as defined in the Queues item.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

"DevPrime_Stream": [
    {
      "Enable": "true",
      "Alias": "Stream1",
      "Default": "true",
      "StreamType": "RabbitMQ",
      "HostName": "amqps://user:password@demo.rmq.cloudamqp.com/demo",
      "Exchange": "devprime",
      "ExchangeType": "direct",
      "Retry": "3",
      "Fallback": "State1",
      "Threads": "30",
      "Buffer": "1",
      "Subscribe": [
        {
          "Queues": "orderevents"
        }
      ]
    }
  ],

In the example below, we’re detailing the default Adapter settings and the RabbitMQ-specific settings.

General —
Enable Enable the Stream adapter (True/False)
Alias Define a unique name to identify the service
Default Sets the default for the centary to have more than one Stream (True/False)
StreamType Sets the Stream Type (RabbitMQ/Kafka)
HostName Configures the url/credential provided by CloudAMQP
Exchange Configures the default RabbitMQ
ExchangeType Configures the Exchange type
Retry Sets the number of retries
Fallback Sets a State for automatic persistence in case of failure
Threads Sets the number of concurrent connections processing events
Buffer Sets the number of events obtained per connection
Subscribe Configures RabbitMQ queues for read

Example in the application log with this configuration:

1
2

[INF][ms-order][Stream][Type "RabbitMQ"][Alias "Stream1"]
["Enable"][Subscribe]["orderevents"][Parallel "30"][Buffer "1"]

YAML example with application settings:
To export the configurations as an environment variable and use in Kubernetes, run the command in the Devprime CLI:
dp export kubernetes

1
2
3
4
5
6

- name: devprime_stream1
    value: "alias=Stream1|||enable=true|||default=true|||streamtype=RabbitMQ|||
    hostname=amqps://user:password@demo.rmq.cloudamqp.com/demo|||
    exchange=devprime|||exchangetype=direct|||retry=3|||
    fallback=State1|||threads=30|||buffer=1|||
    subscribe=[queues=orderevents]"

Use the RabbitMQ examples to explore other variations in the configuration.

Last modified November 20, 2024 (61099f59)