manyi/venv/Lib/site-packages/celery/tests/compat_modules/test_messaging.py

from __future__ import absolute_import

from celery import messaging
from celery.tests.case import AppCase, depends_on_current_app


@depends_on_current_app
class test_compat_messaging_module(AppCase):

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