def METHOD_NAME(self, mock_datadog):
    datadog_mailer_config = {
        "queue_url": "projects/c7n-dev/subscriptions/getnotify",
        "datadog_api_key": "mock_api_key",
        "datadog_application_key": "mock_application_key",
    }
    datadog_compressed_message = MagicMock()
    datadog_compressed_message.content = base64.b64encode(
        zlib.compress(PUBSUB_MESSAGE_DATADOG.encode("utf8"))
    )
    datadog_loaded_message = json.loads(PUBSUB_MESSAGE_DATADOG)
    mock_datadog.return_value.get_datadog_message_packages.return_value = (
        "mock_datadog_message_map"
    )
    pubsub_message = {"message": {"data": datadog_compressed_message.content}}
    gcp_processor = MailerGcpQueueProcessor(datadog_mailer_config, logger)
    gcp_processor.process_message(pubsub_message, "a timestamp")
    mock_datadog.assert_has_calls(
        [call().deliver_datadog_messages("mock_datadog_message_map", datadog_loaded_message)]
    )