old_contents: # (C) Datadog, Inc. 2018-present
  # All rights reserved
  # Licensed under a 3-clause BSD style license (see LICENSE)
  from itertools import product
  
  import pytest
  
  from datadog_checks.activemq_xml import ActiveMQXML
  from datadog_checks.dev.utils import get_metadata_metrics
  
  from .common import CHECK_NAME, CONFIG, GENERAL_METRICS, QUEUE_METRICS, SUBSCRIBER_METRICS, TOPIC_METRICS, URL
  
  
  @pytest.mark.integration
  @pytest.mark.usefixtures("dd_environment")
  def test_integration(aggregator):
      """
      Collect ActiveMQ metrics
      """
      check = ActiveMQXML(CHECK_NAME, {}, [CONFIG])
      check.check(CONFIG)
  
      _test_check(aggregator)
  
  
  @pytest.mark.e2e
  def test_e2e(dd_agent_check):
      aggregator = dd_agent_check(CONFIG)
  
      _test_check(aggregator)
  
      aggregator.assert_metrics_using_metadata(get_metadata_metrics())
  
  
  def _test_check(aggregator):
      tags = ["url:{}".format(URL)]
  
      # Test metrics
      for mname in GENERAL_METRICS:
          aggregator.assert_metric(mname, count=1, tags=tags)
  
      for mname in QUEUE_METRICS:
          aggregator.assert_metric(mname, count=1, tags=tags + ["queue:my_queue"])
  
      for mname, tname in product(TOPIC_METRICS, ["my_topic", "ActiveMQ.Advisory.MasterBroker"]):
          aggregator.assert_metric(mname, count=1, tags=tags + ["topic:{}".format(tname)])
  
      for mname in SUBSCRIBER_METRICS:
          subscriber_tags = tags + [
              "clientId:my_client",
              "connectionId:NOTSET",
              "subscriptionName:my_subscriber",
              "destinationName:my_topic",
              "selector:jms_selector",
              "active:no",
          ]
          aggregator.assert_metric(mname, count=1, tags=subscriber_tags)
  
      aggregator.assert_all_metrics_covered()
  
new_contents: # (C) Datadog, Inc. 2018-present
  # All rights reserved
  # Licensed under a 3-clause BSD style license (see LICENSE)
  from itertools import product
  
  import pytest
  
  from datadog_checks.activemq_xml import ActiveMQXML
  from datadog_checks.dev.utils import get_metadata_metrics
  
  from .common import CHECK_NAME, CONFIG, GENERAL_METRICS, QUEUE_METRICS, SUBSCRIBER_METRICS, TOPIC_METRICS, URL
  
  
  @pytest.mark.integration
  @pytest.mark.usefixtures("dd_environment")
  def test_integration(aggregator, dd_run_check):
      """
      Collect ActiveMQ metrics
      """
      check = ActiveMQXML(CHECK_NAME, {}, [CONFIG])
      dd_run_check(check)
  
      _test_check(aggregator)
  
  
  @pytest.mark.e2e
  def test_e2e(dd_agent_check):
      aggregator = dd_agent_check(CONFIG)
  
      _test_check(aggregator)
  
      aggregator.assert_metrics_using_metadata(get_metadata_metrics())
  
  
  def _test_check(aggregator):
      tags = ["url:{}".format(URL)]
  
      # Test metrics
      for mname in GENERAL_METRICS:
          aggregator.assert_metric(mname, count=1, tags=tags)
  
      for mname in QUEUE_METRICS:
          aggregator.assert_metric(mname, count=1, tags=tags + ["queue:my_queue"])
  
      for mname, tname in product(TOPIC_METRICS, ["my_topic", "ActiveMQ.Advisory.MasterBroker"]):
          aggregator.assert_metric(mname, count=1, tags=tags + ["topic:{}".format(tname)])
  
      for mname in SUBSCRIBER_METRICS:
          subscriber_tags = tags + [
              "clientId:my_client",
              "connectionId:NOTSET",
              "subscriptionName:my_subscriber",
              "destinationName:my_topic",
              "selector:jms_selector",
              "active:no",
          ]
          aggregator.assert_metric(mname, count=1, tags=subscriber_tags)
  
      aggregator.assert_all_metrics_covered()
  
subject: Add dd_run_check (#10381)