@raises(socket.timeout)  # Test must fail :)
    @timed(2)
    def test_subscrible_other_message(self):
        m = Main()
        m.tcp_connect()
        m.send_connect([('login', '1.test'), ('passcode', 'test')])
        m.get_frame()  # Connected frame
        m.send_frame('SUBSCRIBE', [('destination', config.TEST_TOPICS[0]), ('x-ebu-nofastreply', 'yes')], '')

        msg = str(uuid.uuid4())

        m.send_frame('SEND', [('destination', config.TEST_TOPICS[1])], msg)

        m.socket.settimeout(3)

        (result, headers, body) = m.get_frame()
        eq_(result, 'MESSAGE')
        eq_(body, msg)
        eq_(get_header_value(headers, 'destination'), config.TEST_TOPICS[0])
A wrapper around connection.ops.quote_name that doesn't quote aliases
dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py/MainTests.test_subscrible_other_message--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/Django-1.6.10/django/db/models/sql/compiler.py/SQLCompiler.quote_name_unless_alias