​
Step 1: Create a new streaming pipeline

  1. Open Mage in your browser.
  2. Click on ”+ New Pipeline” and select “Streaming”.
  3. Give your pipeline a name and click “Create”.

​
Step 2: Add an ActiveMQ data loader

  1. In your new pipeline, click ”+ Add Block” and select “Data loader”.
  2. Choose “ActiveMQ” as the data source.

​
Step 3: Configure your ActiveMQ connection

In the data loader block, use the following YAML configuration as a template: 
connector_type: 'activemq'
connection_host: 'localhost'
connection_port: 61613
queue_name: 'default'
username: 'admin'
password: 'admin'
Adjust these values according to your ActiveMQ setup:
  • connection_host: Your ActiveMQ broker’s hostname or IP address.
  • connection_port: The port your ActiveMQ broker is listening on (default STOMP port is 61613).
  • queue_name: The name of the queue you want to consume messages from.
  • username and password: Your ActiveMQ authentication credentials.
Ensure that the stomp port on ActiveMQ is open, which is 61613 by default.

​
Step 4: Additional configuration (optional)

Depending on your specific requirements, you may need to add additional configuration options:
  1. For SSL/TLS connections:
use_ssl: true
ssl_cert_path: '/path/to/cert.pem'
ssl_key_path: '/path/to/key.pem'
  1. To set a connection timeout:
connection_timeout: 30 # in seconds
  1. To control message prefetching:
prefetch_size: 100

​
Step 5: Test your connection

  1. Save your data loader block.
  2. Click the “Test” button to verify your connection to ActiveMQ.
  3. If successful, you should see a sample of messages from your queue.