

@timed(2)
def test_subscrible_message_on_all(self):
    'Test if we get message back on all topics if we send a message to /topic/*/'
    m = Main()
    m.tcp_connect()
    m.send_connect([('login', '1.test'), ('passcode', 'test')])
    m.get_frame()
    clients = {
        
    }
    for t in config.TEST_TOPICS:
        m2 = Main()
        clients.tcp_connect()
        m2.send_connect([])
        m2.get_frame()
        m2.send_frame('SUBSCRIBE', [('destination', t), ('x-ebu-nofastreply', 'yes')], '')
        clients[t] = m2
    msg = str(uuid.uuid4())
    m.send_frame('SEND', [('destination', '/topic/*/')], msg)
    for t in config.TEST_TOPICS:
        (result, headers, body) = clients[t].get_frame()
        eq_(result, 'MESSAGE')
        eq_(body, msg)
        eq_(get_header_value(headers, 'destination'), t)

dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py MainTests.test_subscrible_message_on_all/VarMisuse@77/136 `m2`->`clients`