@timed(2)
    def test_message_then_subscrible_gcc_to_cc(self):
        m = Main()
        m.tcp_connect()
        m.send_connect([('login', '3.test'), ('passcode', 'test')])
        m.get_frame()  # Connected frame

        msg = str(uuid.uuid4())

        m.send_frame('SEND', [('destination', config.TEST_ECC_TOPIC_GCC)], msg)
        time.sleep(0.5)
        m.send_frame('SUBSCRIBE', [('destination', config.TEST_ECC_TOPIC_CC)], '')
        (result, headers, body) = m.get_frame()
        eq_(result, 'MESSAGE')
        eq_(body, msg)
        eq_(get_header_value(headers, 'destination'), config.TEST_ECC_TOPIC_CC)
Kick off the test data loader.
dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py/MainTests.test_message_then_subscrible_gcc_to_cc--crossover with--dataset/ETHPy150Open ireapps/census/censusweb/fabfile.py/batch_test