AppDynamics Monitoring Extension for use with IBM Websphere MessageBroker or IIB

Use case

The IBM Integration Bus, formerly known as the IBM WebSphere Message Broker Family, provides a variety of options for implementing a universal integration foundation based on an enterprise service bus (ESB). Implementations help to enable connectivity and transformation in heterogeneous IT environments for businesses of any size, in any industry and covering a range of platforms.

Metrics Provided

This extension extracts resource and message flow statistics. The list of metrics that it extracts can be found here:
Resource Statistics
Flow Statistics

Prerequisites

1. This extension requires a AppDynamics Java Machine Agent installed and running.
2. If this extension is configured for Client transport type (more on that later), please make sure the MQ's host and port is accessible.
3. If this extension is configured for Bindings transport type (more on that later), admin level credentials to the queue manager would be needed. If the hosting OS for IBM MQ is Windows, Windows user credentials will be needed.

Dependencies

This extension requires the IBM MQ JMS client classes. Refer to the IBM documentation for the specific jars.
For IBM MQ 8.0 and above, it depends on the following jars:

com.ibm.mq.allclient.jar
com.ibm.mq.traceControl.jar
fscontext.jar
jms.jar
providerutil.jar

For previous versions,

com.ibm.mqjms.jar
jms.jar

This extension works for Windows, Unix as well as AIX.

Installation

To install the extension, extract the zip file to /monitors/. IBM doesn't recommend copying the IBM jar files into other file locations.
In fact, from MQ version 8.0 onwards, IBM restricts the jars that can be copied. See here There are two configurations needed:

1. On the WebSphere Message Broker
   To get resource statistics from the broker, first you will have to enable the resource statistics on WMB (WebSphere Message Broker).
   
   1. You can run "mqsichangeresourcestats" by running it in IBM Integration Console (in WMB 9.0) or IBM WMB Command Console (in previous versions). A sample command can be

      mqsichangeresourcestats BrokerA -c active -e default 
                   
          where
          BrokerA -> the broker name
          default -> the execution group / integration server
      

      Please follow the below documentation to get more familiar with the mqsichangeresourcestats
   2. To get message flow statistics, you have to enable them for a particular application / message flow:
      

      mqsichangeflowstats BrokerA -e default -k application -f messageflow -s -o xml -c active
      
          where
          BrokerA -> the broker name
          default -> the execution group / integration server
          application -> the application name
          messageflow -> the name of the message flow
      

      Please follow the below documentation to get more familiar with the mqsichangeflowstats
   Once you have started the statistic collection, you can confirm it by viewing the statistics as follows
   

    - Open IBM WebSphere MQ Explorer
    - Click on Integration Node i.e. Broker Name
    - Right click on the execution group which you want statistics for and view resource statistics.
   

   Alternatively you can verify that the collection of statistics is enabled using the Broker's Web Interface.
   The resource metrics get published every 20 seconds to a topic. For the above command, the statistics will get published on this topic $SYS/Broker/BrokerA/ResourceStatistics/default. Similarly, snapshot statistics for message flows get published every 20 seconds to the corresponding topic $SYS/Broker/+/StatisticsAccounting/SnapShot/application/messageflow.
   For more details, please follow the IBM documentation
   The extension subscribes to a particular topic in a queue manager's queue. Please confirm that you have all of the following in the IBM WebSphere MQ explorer:
   1. Queue Manager.
   2. A TCP Listener on some port controlled/managed by Queue Manager. This port will be the port which we will use to subscribe to the statistics from the extension.
   If the queue manager and/or TCP listener is not present, please create them.


2. On the appdynamics extension You can run this extension in Client or Bindings mode. In `Bindings` mode the extension needs to be installed on the same box as the MQ Server. In Client mode the extension needs to be remote and should have the access to the MQ Server.
   
   If you are planning to use it in Bindings mode, please make sure that based on your OS, the IBM library path in the `appd-message-broker-monitor.sh` or `appd-message-broker-monitor.bat` exists and that IBM MQ jar files are available in that location.
   If you are planning to use it in Client mode, please download the right version of IBM MQ Client on that remote server and obtain the above mentioned IBM jars from there.
   
   Configure the config.yml file in the WMBMonitor directory.
   
   

   #This will create the metrics in all the tiers,under this path
       #metricPrefix: "Custom Metrics|WMB"
       
       #This will create the metricUtils in a specific Tier/Component. Make sure to replace the
       # with the appropriate one from your environment. To find the  in your environment
       #,please follow the screenshot here https://docs.appdynamics.com/display/PRO42/Build+a+Monitoring+Extension+Using+Java
       metricPrefix: "Server|Component:|Custom Metrics|WMB"
       
       queueManagers:
         - host: "localhost"
       
           #TCP Listener port. Please make sure that the listener is started.
           port: 2414
       
           #Actual name of the queue manager.
           name: "QMgr1"
       
           #The transport type for the queue manager connection, the default is "Bindings".
           #For bindings type connection WMQ extension (i.e machine agent) need to be on the same machine on which WebsphereMQ server is running
           #for client type connection WMQ extension is remote to the WebsphereMQ server. For client type, Change it to "Client".
           transportType: "Bindings"
       
           #Channel name of the queue manager. Channel should be server-conn type. Make sure the channel is active. It is irrelevant for Bindings Mode
           #channelName: "SYSTEM.ADMIN.SVRCONN"
       
           #userId and password with admin level credentials. For Windows, please provide the administrator credentials. These fields are irrelevant for Bindings Mode
           #userID: ""
           #password: ""
       
           #SSL related properties. Please provide the path.
           #sslKeyRepository: ""
       
           #Cipher Suites. eg. "SSL_RSA_WITH_AES_128_CBC_SHA256"
           #cipherSuite: ""
       
           #Client Connection Name
           clientID: "AppDynamics Extension for Message Broker"
       
           #Resource Statistics Subscribers - https://www.ibm.com/support/knowledgecenter/en/SSMKHH_9.0.0/com.ibm.etools.mft.doc/bj43310_.htm
           #Please make sure to provide unique subscriber name for each statistic subscription.
           resourceStatisticsSubscribers:
             - topic: "$SYS/Broker/+/ResourceStatistics/#"
               subscriberName: "allResourceStatistics"
       
           #Flow Statistics Subscribers - https://www.ibm.com/support/knowledgecenter/en/SSMKHH_9.0.0/com.ibm.etools.mft.doc/aq20080_.htm
           #Please make sure to provide unique subscriber name for each statistic subscription.
           flowStatisticsSubscribers:
             - topic: "$SYS/Broker/+/StatisticsAccounting/SnapShot/#/#"
               subscriberName: "allFlowStatistics"
       
       
           #For resource and flowstatistics, all the fields listed in this section will be reported as metrics.
           #Remove fields you don't need to reduce the number of metricUtils.
           #Available fields:
           #https://www.ibm.com/support/knowledgecenter/SSMKHH_10.0.0/com.ibm.etools.mft.doc/bn43250_.htm
           metrics:
             resourceStatistics:
               - type: "JVM"
                 identifiers: ["summary","Heap Memory","Non-Heap Memory","Garbage Collection - Copy","Garbage Collection - MarkSweepCompact"]
                 include:
                   - InitialMemoryInMB : "InitialMemoryInMB"  #The initial amount of memory that the JVM requests from the operating system for memory management during startup. Its value might be undefined.
                   - UsedMemoryInMB : "UsedMemoryInMB" #The amount of memory that is currently in use.
                   - CommittedMemoryInMB : "CommittedMemoryInMB" #The amount of memory that is allocated to the JVM by the operating system.
                   - MaxMemoryInMB : "MaxMemoryInMB" #The maximum amount of memory that can be used for memory management. Its value might be undefined.
                   - CumulativeNumberOfGCCollections : "CumulativeNumberOfGCCollections" #The total number of garbage collections that have occurred for this instance of the JVM. Its value might be undefined.
       
               - type: "JDBCConnectionPools"
                 identifiers: ["summary"]
                 include:
                   - MaxSizeOfPool : "MaxSizeOfPool"  #The maximum size of the connection pool.
                   - ActualSizeOfPool : "ActualSizeOfPool"   #A snapshot of the number of connections currently in the pool when the statistics were reported.
                   - CumulativeRequests : "CumulativeRequests"  #A count of the number of requests received by the connection pool during this accounting period.
                   - CumulativeDelayedRequests : "CumulativeDelayedRequests"  #The number of times a request for a connection could not be satisfied immediately, because the number of allocated connections reached the maximum pool size and no connections are currently available.
                   - MaxDelayInMilliseconds : "MaxDelayInMilliseconds"  #The maximum time a caller waited for a connection to be allocated, in milliseconds.
                   - CumulativeTimedOutRequests : "CumulativeTimedOutRequests"  #A count of the number of requests for connections that could not be satisfied within 15 seconds.
       
               - type: "JMS"
                 identifiers: ["summary"]
                 include:
                   - NumberOfOpenJMSConnections : "NumberOfOpenJMSConnections" #The current number of open JMS connections.
                   - NumberOfClosedJMSConnections : "NumberOfClosedJMSConnections"  #The total number of JMS connections that were closed since the last integration server restart.
                   - NumberOfOpenJMSSessions : "NumberOfOpenJMSSessions"  #The current number of open JMS sessions.
                   - NumberOfClosedJMSSessions : "NumberOfClosedJMSSessions"  #The total number of JMS sessions that were closed since the last integration server restart.
                   - NumberOfMessagesReceived : "NumberOfMessagesReceived"  #The total number of messages received by JMSInput or JMSReceive nodes.
                   - NumberOfMessagesSent : "NumberOfMessagesSent" #The total number of messages sent by JMSOutput nodes.
                   - NumberOfMessagesBrowsed : "NumberOfMessagesBrowsed"  #The total number of messages browsed by JMSReceive nodes.
                   - NumberOfJMSConnectionFailures : "NumberOfJMSConnectionFailures"  #The total number of attempted JMS connections that failed since the last integration server restarts.
       
               - type: "Sockets"
                 identifiers: ["summary"]
                 include:
                   - TotalSockets : "TotalSockets"    #The number of outbound sockets that have been opened since the last integration server restart.
                   - TotalMessages : "TotalMessages"  #The number of requests for a socket; for example, from a SOAPRequest node.
                   - TotalDataSent_KB : "TotalDataSent_KB"  #The number of bytes sent, in kilobytes (KB).
                   - TotalDataReceived_KB : "TotalDataReceived_KB"  #The number of bytes received, in kilobytes (KB).
                   - SentMessageSize_10KB-100KB : "SentMessageSize_10KB-100KB" #The number of messages sent in each size range. For example, a message of 999 bytes is counted in SentMessageSize_0-1KB; a message of 1000 bytes is counted in SentMessageSize_1KB-10KB.
       
               - type: "TCPIPClientNodes"
                 identifiers: ["summary"]
                 include:
                   - OpenConnections: "OpenConnections" #The current number of open connections
                   - ClosedConnections: "ClosedConnections" #The total number of connections that were closed since the last integration server restart
                   - MessagesReceived: "MessagesReceived" #The total number of messages received (by TCPIPClientInput or TCPIPClientReceive nodes)
                   - MessagesSent : "MessagesSent" #The total number of messages sent (by TCPIPClientOutput nodes)
                   - BytesSent : "BytesSent" #The total amount of data sent (by TCPIPClientOutput nodes), excluding SSL wrappers.
                   - BytesReceived: "BytesReceived"  #The total amount of data received (by TCPIPClientInput or TCPIPClientReceive nodes),  excluding SSL wrappers.
                   - FailedConnections : "FailedConnections"  #The total number of attempted connections that failed since the last integration server restarts.
       
               - type: "TCPIPServerNodes"
                 identifiers: ["summary"]
                 include:
                   - OpenConnections: "OpenConnections" #The current number of open connections
                   - ClosedConnections: "ClosedConnections" #The total number of connections that were closed since the last integration server restart
                   - MessagesReceived: "MessagesReceived" #The total number of messages received (by TCPIPClientInput or TCPIPClientReceive nodes)
                   - MessagesSent : "MessagesSent" #The total number of messages sent (by TCPIPClientOutput nodes)
                   - BytesSent : "BytesSent" #The total amount of data sent (by TCPIPClientOutput nodes), excluding SSL wrappers.
                   - BytesReceived: "BytesReceived"  #The total amount of data received (by TCPIPClientInput or TCPIPClientReceive nodes),  excluding SSL wrappers.
                   - FailedConnections : "FailedConnections"  #The total number of attempted connections that failed since the last integration server restarts.
       
             flowStatistics:
               - type: "MessageFlow"
                 identifiers: [""]
                 include:
                   - TotalElapsedTime : "TotalElapsedTime"  #Total elapsed time spent processing input messages (microseconds)
                   - MaximumElapsedTime : "MaximumElapsedTime"  #Maximum elapsed time that is spent processing an input message (microseconds)
                   - MinimumElapsedTime : "MinimumElapsedTime"  #Minimum elapsed time that is spent processing an input message (microseconds)
                   - TotalCPUTime : "TotalCPUTime" #Total processor time spent processing input messages (microseconds)
                   - MaximumCPUTime : "MaximumCPUTime" #Maximum processor time that is spent processing an input message (microseconds)
                   - MinimumCPUTime : "MinimumCPUTime" #Minimum processor time that is spent processing an input message (microseconds)
                   - CPUTimeWaitingForInputMessage : "CPUTimeWaitingForInputMessage" #Total processor time spent waiting for input messages (microseconds)
                   - ElapsedTimeWaitingForInputMessage : "ElapsedTimeWaitingForInputMessage" #	Total elapsed time that is spent waiting for input messages (microseconds)
                   - TotalInputMessages: "TotalInputMessages" #Total number of messages processed.TotalInputMessages records only those messages that are propagated from input node terminals.
                   - TotalSizeOfInputMessages : "TotalSizeOfInputMessages"  #Total size of input messages (bytes)
                   - MaximumSizeOfInputMessages : "MaximumSizeOfInputMessages"   #Maximum input message size (bytes)
                   - MinimumSizeOfInputMessages : "MinimumSizeOfInputMessages" #Minimum message input size (bytes)
                   - NumberOfThreadsInPool : "NumberOfThreadsInPool"  #Number of threads in pool
                   - TimesMaximumNumberofThreadsReached : "TimesMaximumNumberofThreadsReached"  #Number of times the maximum number of threads is reached
                   - TotalNumberOfMQErrors : "TotalNumberOfMQErrors"   #Number of MQGET errors (MQInput node) or web services errors (HTTPInput node). For example, a conversion error occurs when the message is got from the queue.
                   - TotalNumberOfMessagesWithErrors : "TotalNumberOfMessagesWithErrors"       #Number of messages that contain errors
                   - TotalNumberOfErrorsProcessingMessages : "TotalNumberOfErrorsProcessingMessages"   #Number of errors when processing a message
                   - TotalNumberOfTimeOutsWaitingForRepliesToAggregateMessages : "TotalNumberOfTimeOutsWaitingForRepliesToAggregateMessages"  #Number of timeouts when processing a message (AggregateReply node only)
                   - TotalNumberOfCommits : "TotalNumberOfCommits"  #Number of transaction commits
                   - TotalNumberOfBackouts : "TotalNumberOfBackouts"     #Number of transaction backouts
       
               - type: "Threads"
                 identifiers: ["ThreadStatistics"]
                 include:
                   - TotalNumberOfInputMessages : "TotalNumberOfInputMessages"  #Total number of messages that are processed by a thread
                   - TotalElapsedTime: "TotalElapsedTime" #Total elapsed time spent processing input messages (microseconds)
                   - TotalCPUTime : "TotalCPUTime" #Total processor time spent processing input messages (microseconds)
                   - CPUTimeWaitingForInputMessage : "CPUTimeWaitingForInputMessage"  #Total processor time spent waiting for input messages (microseconds)
                   - ElapsedTimeWaitingForInputMessage : "ElapsedTimeWaitingForInputMessage" #Total elapsed time that is spent waiting for input messages (microseconds)
                   - TotalSizeOfInputMessages : "TotalSizeOfInputMessages"    #Total size of input messages (bytes)
                   - MaximumSizeOfInputMessages : "MaximumSizeOfInputMessages"    #Maximum size of input messages (bytes)
                   - MinimumSizeOfInputMessages : "MinimumSizeOfInputMessages"  #Minimum size of input messages (bytes)
       
               - type: "Nodes"
                 identifiers: ["NodeStatistics"]
                 include:
                   - Number: "Number" #Number of node statistics subfolders in Nodes folder
                   - TotalElapsedTime: "TotalElapsedTime"  #Total elapsed time spent processing input messages (microseconds)
                   - MaximumElapsedTime : "MaximumElapsedTime"  #Maximum elapsed time spent processing input messages (microseconds)
                   - MinimumElapsedTime : "MinimumElapsedTime"  #Minimum elapsed time spent processing input messages (microseconds)
                   - TotalCPUTime : "TotalCPUTime"  #Total processor time spent processing input messages (microseconds)
                   - MaximumCPUTime : "MaximumCPUTime"  #Maximum processor time spent processing input messages (microseconds)
                   - MinimumCPUTime : "MinimumCPUTime"  #Minimum processor time spent processing input messages (microseconds)
                   - CountOfInvocations : "CountOfInvocations"  #Total number of messages that are processed by this node
                   - NumberOfInputTerminals: "NumberOfInputTerminals"    #Number of input terminals
                   - NumberOfOutputTerminals : "NumberOfOutputTerminals"  #Number of output terminals
       
               - type: "Nodes"
                 identifiers: ["NodeStatistics|TerminalStatistics"]
                 include:
                   - CountOfInvocations : "CountOfInvocations"  #Total number of messages that are processed by this node
       
           derivedMetrics:
             flowStatistics:
               - type: "MessageFlow"
                 identifiers: [""]
                 include:
                   - AverageElapsedTime : "AverageElapsedTime"
                   - AverageCPUTime: "AverageCPUTime"
                   - AverageCPUTimeWaitingForInputMessage: "AverageCPUTimeWaitingForInputMessage"
                   - AverageSizeOfInputMessages: "AverageSizeOfInputMessages"
       
               - type: "Threads"
                 identifiers: ["ThreadStatistics"]
                 include:
                   - AverageElapsedTime: "AverageElapsedTime"
                   - AverageCPUTime: "AverageCPUTime"
                   - AverageCPUTimeWaitingForInputMessage: "AverageCPUTimeWaitingForInputMessage"
                   - AverageElapsedTimeWaitingForInputMessage: "AverageElapsedTimeWaitingForInputMessage"
                   - AverageSizeOfInputMessages: "AverageSizeOfInputMessages"
       
               - type: "Nodes"
                 identifiers: ["NodeStatistics"]
                 include:
                   - AverageElapsedTime: "AverageElapsedTime"
                   - AverageCPUTime: "AverageCPUTime"
       
       
       #Don't change this unless you are having more than 10 queue managers to monitor.
       numberOfThreads: 10
       
       #Don't change this.
       machineAgentWatchDog:
         #In seconds
         initialDelay: 0
         #Check the existence of MA process in 'period' seconds.
         period: 5
   

Performance Overhead

There may be a performance overhead on activating resource and flow stats in your IIB environment. Here is what IBM has documented about the performance impact.

Support for AIX

This extension works on AIX if you point to

 <file os-type="linux">appd-message-broker-monitor.sh</file> 

in the monitor.xml and change the appd-message-broker-monitor.sh and process_checker.sh files to using korn shell.

Metric Properties

You may see some metrics as an ever increasing counter. Sometimes that is helpful but most of the times you may just want to see the change in that minute for a particular metric. We let you configure that in the config.yml for each metric.

          - type: "TCPIPClientNodes"
              identifiers: ["summary"]
              include:
                - OpenConnections: "OpenConnections" #The current number of open connections
                - MessagesReceived: "MessagesReceived" #The total number of messages received (by TCPIPClientInput or TCPIPClientReceive nodes)
                  delta: true
                  metricType: "SUM SUM INDIVIDUAL"
                - MessagesSent : "MessagesSent" #The total number of messages sent (by TCPIPClientOutput nodes)
                  delta: true
                  metricType: "SUM SUM INDIVIDUAL"
                - BytesSent : "BytesSent" #The total amount of data sent (by TCPIPClientOutput nodes), excluding SSL wrappers.
                  delta: true
                  metricType: "SUM SUM INDIVIDUAL"
                - BytesReceived: "BytesReceived"  #The total amount of data received (by TCPIPClientInput or TCPIPClientReceive nodes),  excluding SSL wrappers.
                  delta: true
                  metricType: "SUM SUM INDIVIDUAL"
                - FailedConnections : "FailedConnections"  #The total number of attempted connections that failed since the last integration server restarts.
                  delta: true
                  metricType: "SUM SUM INDIVIDUAL"

In the above configuration, for MessagesReceived,MessagesSent,BytesSent,BytesReceived,FailedConnections, we have configured two properties delta and metricType.
delta - For each metric that has delta: true, the extension calculates a difference between the current and previous value and reports the difference. Default value for delta: false
metricType - It let's you define the metric qualifiers for the particular metric.
The format is "(Aggregation Qualifier) (Time Roll Up Qualifier) (Cluster Roll Up Qualifier)". To know more about these qualifiers, please visit this link

 In the above example, metricType: "SUM SUM INDIVIDUAL", means
   Aggregation Qualifier = SUM
   Time Roll Up Qualifier = SUM
   Cluster Roll Up Qualifier = INDIVIDUAL.

Troubleshooting

1. Verify Machine Agent Data: Please start the Machine Agent without the extension and make sure that it reports data. Verify that the machine agent status is UP and it is reporting Hardware Metrics.
2. config.yml: Validate the file here
3. MQ Version incompatibilities : In case of any jar incompatibility issue, the rule of thumb is to use the jars from MQ version 8.0.
4. Metric Limit: Please start the machine agent with the argument -Dappdynamics.agent.maxMetrics=5000 if there is a metric limit reached error in the logs. If you don't see the expected metrics, this could be the cause.
5. Check Logs: There could be some obvious errors in the machine agent logs. Please take a look.
6. The config cannot be null error.
This usually happens when on a windows machine in monitor.xml you give config.yml file path with linux file path separator /. Use Windows file path separator \ e.g. monitors\MQMonitor\config.yaml. For Windows, please specify the complete path.
7. Please confirm whether the resourcestats and flowstats were enabled for the queue manager and the listener port is up.
8. Collect Debug Logs: Edit the file, */conf/logging/log4j.xml* and update the level of the appender *com.appdynamics* and *com.singularity* to debug. Let it run for 5-10 minutes and attach the logs to a support ticket.

Custom Dashboard

 

Contributing

Always feel free to fork and contribute any changes directly via GitHub.

Support

For any questions or feature request, please contact AppDynamics Support.