IBM MQ Metricbeat module

x-pack/metricbeat/main.go

@@ -15,6 +15,8 @@ import (
 	"os"
 
 	"github.com/elastic/beats/x-pack/metricbeat/cmd"
+	_ "github.com/felix-lessoer/beats/x-pack/metricbeat/module/ibmmq"
+	_ "github.com/felix-lessoer/beats/x-pack/metricbeat/module/ibmmq/qmgr"
 )
 
 func main() {

x-pack/metricbeat/metricbeat.reference.yml

@@ -412,6 +412,34 @@ metricbeat.modules:
   #    fields: # added to the the response in root. overwrites existing fields
   #      key: "value"
 
+#-------------------------------- Ibmmq Module --------------------------------
+- module: ibmmq
+  metricsets: ["qmgr"]
+  period: 10s
+  hosts: ["localhost"]
+  enabled: true
+
+  #client_id: metricbeat
+  #retries: 3
+  #backoff: 250ms
+
+  # List of Topics to query metadata for. If empty, all topics will be queried.
+  #topics: []
+
+  # Optional SSL. By default is off.
+  # List of root certificates for HTTPS server verifications
+  #ssl.certificate_authorities: ["/etc/pki/root/ca.pem"]
+
+  # Certificate for SSL client authentication
+  #ssl.certificate: "/etc/pki/client/cert.pem"
+
+  # Client Certificate Key
+  #ssl.key: "/etc/pki/client/cert.key"
+
+  # SASL authentication
+  #username: ""
+  #password: ""
+
 #------------------------------- Jolokia Module -------------------------------
 - module: jolokia
   #metricsets: ["jmx"]

x-pack/metricbeat/module/ibmmq/_meta/config.reference.yml

@@ -0,0 +1,26 @@
+- module: ibmmq
+  metricsets: ["qmgr"]
+  period: 10s
+  hosts: ["localhost"]
+  enabled: true
+
+  #client_id: metricbeat
+  #retries: 3
+  #backoff: 250ms
+
+  # List of Topics to query metadata for. If empty, all topics will be queried.
+  #topics: []
+
+  # Optional SSL. By default is off.
+  # List of root certificates for HTTPS server verifications
+  #ssl.certificate_authorities: ["/etc/pki/root/ca.pem"]
+
+  # Certificate for SSL client authentication
+  #ssl.certificate: "/etc/pki/client/cert.pem"
+
+  # Client Certificate Key
+  #ssl.key: "/etc/pki/client/cert.key"
+
+  # SASL authentication
+  #username: ""
+  #password: ""

x-pack/metricbeat/module/ibmmq/_meta/config.yml

@@ -0,0 +1,11 @@
+# Module: ibmmq
+# Docs: https://www.elastic.co/guide/en/beats/metricbeat/master/metricbeat-module-ibmmq.html
+
+- module: ibmmq
+  #metricsets:
+  #  - qmgr
+  period: 10s
+
+  hosts: ["localhost"]
+  #username: guest
+  #password: guest

x-pack/metricbeat/module/ibmmq/_meta/docs.asciidoc

@@ -0,0 +1,9 @@
+This is the IBM MQ metricbeat module. This module uses PCF messages to collect metrics and status information from different IBM MQ objects.
+With IBM MQ > v9 its also possible to collect data using the subscribe mode.
+
+At the moment this is collecting data from Queue Manager.
+
+[float]
+=== Compability
+
+This module is tested with IBM MQ v9.1.0 but older version will work as well. The subscribe mode only works with IBM MQ > v9.

x-pack/metricbeat/module/ibmmq/_meta/fields.yml

@@ -0,0 +1,11 @@
+- key: ibmmq
+  title: "ibmmq"
+  description: >
+    experimental[]
+
+    ibmmq module
+  fields:
+    - name: ibmmq
+      type: group
+      description: >
+      fields:

x-pack/metricbeat/module/ibmmq/ibmmq.go

@@ -0,0 +1,9 @@
+// Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+// or more contributor license agreements. Licensed under the Elastic License;
+// you may not use this file except in compliance with the Elastic License.
+
+package ibmmq
+
+import "github.com/elastic/beats/libbeat/logp"
+
+var debugf = logp.MakeDebug("ibmmq")