ActiveMQ and Graylog Integration

Input and output integration overview

The ActiveMQ Input Plugin collects metrics from the ActiveMQ message broker through its Console API, providing insights into the performance and status of message queues, topics, and subscribers.

The Graylog plugin allows you to send Telegraf metrics to a Graylog server, utilizing the GELF format for structured logging.

Integration details

ActiveMQ

The ActiveMQ Input Plugin interfaces with the ActiveMQ Console API to gather metrics related to queues, topics, and subscribers. ActiveMQ, a widely-used open-source message broker, supports various messaging protocols and provides a robust Web Console for management and monitoring. This plugin allows users to track essential metrics including queue sizes, consumer counts, and message counts across different ActiveMQ entities, thereby enhancing observability within messaging systems. Users can configure various parameters such as the WebConsole URL and basic authentication credentials to tailor the plugin to their environment. The metrics collected can be used for monitoring the health and performance of messaging applications, facilitating proactive management and troubleshooting.

Graylog

The Graylog plugin is designed for sending metrics to a Graylog instance using the GELF (Graylog Extended Log Format) format. GELF helps standardize the logging data, making it easier for systems to send and analyze logs. The plugin adheres to the GELF specification, which lays out requirements for specific fields within the payload. Notably, the timestamp must be in UNIX format, and if present, the plugin sends the timestamp as-is to Graylog without alterations. If omitted, it automatically generates a timestamp. Additionally, any extra fields not explicitly defined by the spec will be prefixed with an underscore, helping to keep the data organized and compliant with GELF’s requirements. This capability is particularly valuable for users monitoring applications and infrastructure in real-time, as it allows for seamless integration and improved visibility across multiple systems.

Configuration

ActiveMQ

[[inputs.activemq]]
  ## ActiveMQ WebConsole URL
  url = "http://127.0.0.1:8161"

  ## Required ActiveMQ Endpoint
  ##   deprecated in 1.11; use the url option
  # server = "192.168.50.10"
  # port = 8161

  ## Credentials for basic HTTP authentication
  # username = "admin"
  # password = "admin"

  ## Required ActiveMQ webadmin root path
  # webadmin = "admin"

  ## Maximum time to receive response.
  # response_timeout = "5s"

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  ## Use TLS but skip chain & host verification
  # insecure_skip_verify = false

Graylog

[[outputs.graylog]]
  ## Endpoints for your graylog instances.
  servers = ["udp://127.0.0.1:12201"]

  ## Connection timeout.
  # timeout = "5s"

  ## The field to use as the GELF short_message, if unset the static string
  ## "telegraf" will be used.
  ##   example: short_message_field = "message"
  # short_message_field = ""

  ## According to GELF payload specification, additional fields names must be prefixed
  ## with an underscore. Previous versions did not prefix custom field 'name' with underscore.
  ## Set to true for backward compatibility.
  # name_field_no_prefix = false

  ## Connection retry options
  ## Attempt to connect to the endpoints if the initial connection fails.
  ## If 'false', Telegraf will give up after 3 connection attempt and will
  ## exit with an error. If set to 'true', the plugin will retry to connect
  ## to the unconnected endpoints infinitely.
  # connection_retry = false
  ## Time to wait between connection retry attempts.
  # connection_retry_wait_time = "15s"

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  ## Use TLS but skip chain & host verification
  # insecure_skip_verify = false

Input and output integration examples

ActiveMQ

1. Proactive Queue Monitoring: Use the ActiveMQ plugin to monitor queue sizes in real-time for a high-volume trading application. This implementation allows teams to receive alerts when queue sizes exceed a certain threshold, enabling rapid response to potential downtime caused by backlogs, thereby ensuring continuous availability of trading operations.

2. Performance Baselines and Anomaly Detection: Integrate this plugin with machine learning frameworks to establish performance baselines for message throughput. By analyzing historical data collected through this plugin, teams can flag anomalies in processing rates, leading to quicker identification of issues impacting service reliability and performance.

3. Cross-Messaging System Analytics: Combine metrics from ActiveMQ with those from other messaging systems in a centralized dashboard. Users can visualize and compare performance data, such as enqueue and dequeue rates, providing valuable insights into the overall messaging architecture and assisting in optimizing the message flow between different brokers.

4. Subscriber Performance Insights: Leverage the subscriber metrics collected by this plugin to analyze behavior patterns and optimize configuration for consumer applications. Understanding metrics such as dispatched queue size and counter values can guide adjustments to improve processing efficiency and resource allocation.

Graylog

1. Enhanced Log Management for Cloud Applications: Use the Graylog Telegraf plugin to aggregate logs from cloud-deployed applications across multiple servers. By integrating this plugin, teams can centralize logging data, making it easier to troubleshoot issues, monitor application performance, and maintain compliance with logging standards.

2. Real-Time Security Monitoring: Leverage the Graylog plugin to collect and send security-related metrics and logs to a Graylog server for real-time analysis. This allows security teams to quickly identify anomalies, track potential breaches, and respond to incidents promptly by correlating logs from various sources within the infrastructure.

3. Dynamic Alerting and Notification System: Implement the Graylog plugin to enhance alerting mechanisms in your infrastructure. By sending metrics to Graylog, teams can set up dynamic alerts based on log patterns or unexpected behavior, enabling proactive monitoring and rapid incident response strategies.

4. Cross-Platform Log Consolidation: Use the Graylog plugin to facilitate cross-platform log consolidation across diverse environments such as on-premises, hybrid, and cloud. By standardizing logging in the GELF format, organizations can ensure consistent monitoring and troubleshooting practices, regardless of where their services are hosted.

Feedback

Thank you for being part of our community! If you have any general feedback or found any bugs on these pages, we welcome and encourage your input. Please submit your feedback in the InfluxDB community Slack.