ActiveMQ Ingress Configuration

ActiveMQ data ingestion is available using ingress of type activemq.

Examples Repo

Example ActiveMQ configuration files showcasing all features we will discuss can be found in our Examples Repo .

Settings

The ActiveMQ settings in the configuration file are used to configure data ingestion from ActiveMQ topics and queues. Below is a detailed description of each field within the ActiveMQ settings:

Field Required Configurable Description
destination true true The topic or queue to ingress, starting with either topic:// or queue://.
contentType false true The content type of the message, accepted types: avro, csv, json, recon, xml (default plaintext).
avroSchema false true The Avro schema for the message, required if using Avro serialization.

ActiveMQ allows fields to be set using reflection, any field with a set method on the ConnectionFactory can be set within the settings section of the ingress. Here are a few example fields that become available:

Field Required Configurable Description
brokerURL false true Connection URL used to connect to the ActiveMQ broker.
clientID false true JMS clientID to use for the created connection.
userName false true JMS userName used by connections created by this factory.

Message Structure

The message structure of received ActiveMQ messages is:

{ "id": ..., "value": {...} }

Example

The configuration below defines an ActiveMQ ingress where messages are consumed from the specified ActiveMQ topic and relayed to a singleton receiver agent.

{
  "ingress": {
    "type": "activemq",
    "settings": {
      "destination": "topic://test-topic",
      "brokerURL": "tcp://host.docker.internal:61616"
    },
    "relay": {
      "agent": "receiver"
    }
  }
}

Nstream is licensed under the Redis Source Available License 2.0 (RSALv2).