Neflexity

• Anypoint MQ Usage Monitoring and Reporting One of the key features of Qflex-AMQ is the ability to monitor your Anypoint MQ usage, both in terms of API calls and billable units used. With comprehensive usage monitoring and reporting, you'll have complete visibility into your Anypoint MQ costs, helping you optimize your consumption and avoid unexpected billing surprises.
• Queue Statistics Reporting Across Multiple Destinations Qflex-AMQ takes queue monitoring to the next level by providing detailed statistics reporting across multiple destinations. You'll be able to monitor queue performance and usage across your entire Anypoint MQ environment, giving you the insights needed to make data-driven decisions on scaling, optimization, and overall performance management.
• Enhanced Queue Details Screen with Message Activity Charts We've made significant improvements to the queue details screen in Qflex-AMQ, now including message activity charts. These visualizations allow you to quickly identify trends, patterns, and potential bottlenecks in your Anypoint MQ environment. With an enhanced view of message activity, you'll be better equipped to address issues proactively and keep your messaging system running smoothly.
• UI for Monitoring and SchedulingMakes it easy and intuitive to setup monitors and even promote to other environments to save on time.
• Purge Queue (move all messages off the queue to any target queue)
• Export queue contents without consuming messages.
• Move and publish messages between queues.

Sample URL to access Web UI:

http://xxx-anypoint-mq-api-dev.us-e2.cloudhub.io/?client_id=XXXXX&client_secret=YYYYY

• Queue Depth >= and Queue Depth <=
• Queue In-Flight Count >= and Queue In-Flight Count <=
• Queue Messages Sent Count >= and Queue Messages Sent Count <=
• Queue Dequeue Rate Less Than %
• Stale Messages
• MQ Changes Detected
• Monthly Billable Unit Count >=

The number of messages processed through the queue during the period from (now - polling interval) to now.

The number of messages currently locked and processing from the queue during the period from (now - polling interval) to now.

Anypoint MQ FIFO queues supports up to 10 in-flight messages in each message group thus it's important to keep track of the in-flight depth of FIFO queues.

The number of messages published to the queue during the period from (now - polling interval) to now.

The number of messages consumed from the queue during the period from (now - polling interval) to now.

The rate at which messages are removed/consumed from the queue as opposed to the rate at which queue is getting filled on time interval from (now - polling interval) to now.

Triggered by finding Anypoint MQ changes in audit logs based on time interval from (now - polling interval) to now.

This information is import to keep track of in case of unexpected changes to production definitions of your queues and exchanges to prevent critical issues before they happen.

Must have 0.2 v-core available in the targeted CloudHub environments. Although we run all our tests against 0.1v-core without any issues we do recommend 0.2v-cores for any application running in CloudHub.

Deploy Qflex-AMQ application .zip to any environment using any naming convention. There is no need to deploy more than 1 instance of Qflex-AMQ application in order to monitor all of your Anypoint MQ environments. Environment as well as organization name is configurable within the monitor itself using corresponding names (ids will be automatically discovered using Anypoint profile endpoint). Once application is up and running, it will initiate creation of all alerts within the default environment (only in beta version, release will propagate the changes to all environments).

Setup Connected App for Qflex-AMQ application under Access Management using all scopes outlined in the Setup Connected App Qflex-AMQ

Upon application start up, you will find the following alerts generated in your default environment (set through CloudHub properties above). Note, these are provided as templates and can be further modified per your organization’s conventions.

Email examples

Discover the powerful new features and enhanced UI designed to elevate your user experience and streamline your messaging environment.

1. Enhanced User Interface: Our redesigned UI offers an intuitive, user-friendly experience. Effortlessly navigate and access the information you need in a visually engaging layout.
2. Comprehensive Monitoring and Reporting: Qflex-AMQ now delivers extensive monitoring capabilities, including real-time data, historical analysis, and customizable alerts to keep you informed and in control of your messaging infrastructure.
3. Performance Optimization: Monitor and manage Anypoint MQ performance with insightful metrics, allowing for proactive issue identification and resolution to keep your system running smoothly.
4. Seamless Integration: Qflex-AMQ integrates seamlessly within your Anypoint, ensuring a smooth transition and minimal disruption to your current workflows.

We are going to utilize functional monitors as a scheduling tool for invoking Qflex-AMQ monitors so you can add as many endpoints to a single monitor that satisfied your polling interval. For example, you can setup all the monitors to run on hourly basis thus needing only a single functional monitor setup.

1. Create new monitor by pressing Create Monitor in the top right corner.
2. Give any desired name.
3. Select proper location (private location in case of DLB)
4. Select monitor schedule (hourly as an example)
5. On the next screen, switch to Code Editor and use one of the provided examples below or setup endpoints manually.
6. Click Next and skip notifications by pressing Create Monitor (we don't need notifications since these functional monitors will be utilized as smart schedulers for Qflex-AMQ monitoring needs).

Below you will find monitor templates to be used in the functional monitors code editor.

• Queue Depth >= and Queue Depth <=

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue Depth >= 5") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias": "q-depth-gte","priority": "WARN","threshold": 5,"pollingInterval": 15,"intervalBetweenOccurrences": 60,"destinations": ["order(.*)-q","(.*)-dlq"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Queue In-Flight Count >= and Queue In-Flight Count <=

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue Inflight Depth >= 8") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias": "q-inflight-depth-gte","priority": "WARN","threshold": 8,"pollingInterval": 15,"intervalBetweenOccurrences": 60,"destinations": ["(.*)-fifo(.*)"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Queue Messages Sent Count >= and Queue Messages Sent Count <=

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue Sent Depth >= 10") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias": "q-sent-depth-gte","priority": "WARN","threshold": 10,"pollingInterval": 15,"intervalBetweenOccurrences": 60,"destinations": ["(.*)-dlq"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Queue Messages Received Count >= and Queue Messages Received Count <=

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue Received Depth >= 10") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias": "q-received-depth-gte","priority": "WARN","threshold": 10,"pollingInterval": 15,"intervalBetweenOccurrences": 60,"destinations": ["(.*)-dlq"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Queue QoS Dequeue Rate Less Than %

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue QoS Dequeue Rate <= 80%") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias": "q-qos-dequeue-rate-lte","priority": "WARN","threshold": 80,"pollingInterval": 15,"intervalBetweenOccurrences": 60,"destinations": ["(.*)-q"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Stale Messages
• MQ Changes Detected

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Any MQ Changes Detector") in [
    it should "Assert endpoint: " in [
      POST `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/monitors?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": [{"alias":"audit-detect-mq-changes","priority":"ERROR","threshold":0,"pollingInterval":15,"intervalBetweenOccurrences":0,"destinations":["(.*)"]}]
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]

• Queue Message Mover (Cut from queue X and Push to target queue Y)

  import * from bat::BDD
  import * from bat::Assertions
  ---
  suite("NFX-MQ Queue Message Mover") in [
    it should "Assert endpoint: " in [
      DELETE `http://<APP-NAME>.us-e2.cloudhub.io/api/on-demand/destinations/<SOURCE-QUEUE>/messages?organizationName=<ORG-NAME>&environmentName=<ENV-NAME>` with {
        "headers": {
          "Content-Type": "application/json",
          "client_id": "<CLIENT-ID>",
          "client_secret": "<CLIENT-SECRET>"
        },"body": {"targetQueue":"<TARGET-QUEUE>"}
      } assert [
          $.response.status mustEqual 200
      ]
    ]
  ]