# Path: aodh/messaging.py
# DEFAULT_URL = "__default__"
# TRANSPORTS = {}
# _SERIALIZER = oslo_serializer.JsonPayloadSerializer()
# def setup():
# def get_transport(conf, url=None, optional=False, cache=True):
# def get_batch_notification_listener(transport, targets, endpoints,
#                                     allow_requeue=False,
#                                     batch_size=1, batch_timeout=None):
# def get_notifier(transport, publisher_id):


import fixtures
import functools
import os.path
import unittest
import oslo_messaging.conffixture
import webtest
import aodh
from oslo_utils import timeutils
from oslotest import base
from aodh import messaging
#
# Copyright 2012 New Dream Network (DreamHost)
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
"""Test base classes.
"""




class BaseTestCase(base.BaseTestCase):
    def setup_messaging(self, conf, exchange=None):
        self.useFixture(oslo_messaging.conffixture.ConfFixture(conf))
        conf.set_override("notification_driver", ["messaging"])
        if not exchange:
            exchange = 'aodh'
        conf.set_override("control_exchange", exchange)

        # NOTE(sileht): Ensure a new oslo.messaging driver is loaded
        # between each tests

# Path: aodh/messaging.py
# DEFAULT_URL = "__default__"
# TRANSPORTS = {}
# _SERIALIZER = oslo_serializer.JsonPayloadSerializer()
# def setup():
# def get_transport(conf, url=None, optional=False, cache=True):
# def get_batch_notification_listener(transport, targets, endpoints,
#                                     allow_requeue=False,
#                                     batch_size=1, batch_timeout=None):
# def get_notifier(transport, publisher_id):


# Path: aodh/tests/base.py
import fixtures
import functools
import os.path
import unittest
import oslo_messaging.conffixture
import webtest
import aodh
from oslo_utils import timeutils
from oslotest import base
from aodh import messaging

#
# Copyright 2012 New Dream Network (DreamHost)
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
"""Test base classes.
"""




class BaseTestCase(base.BaseTestCase):
    def setup_messaging(self, conf, exchange=None):
        self.useFixture(oslo_messaging.conffixture.ConfFixture(conf))
        conf.set_override("notification_driver", ["messaging"])
        if not exchange:
            exchange = 'aodh'
        conf.set_override("control_exchange", exchange)

        # NOTE(sileht): Ensure a new oslo.messaging driver is loaded
        # between each tests

        self.transport = messaging.get_transport(conf, "fake://", cache=False)