celery/celery/tests/test_compat/test_messaging.py

from celery import messaging
from celery.tests.utils import unittest


class test_compat_messaging_module(unittest.TestCase):

    def test_with_connection(self):

        def foo(**kwargs):
            pass

        self.assertTrue(messaging.with_connection(foo))

    def test_get_consume_set(self):
        conn = messaging.establish_connection()
        messaging.get_consumer_set(conn).close()
        conn.close()