@timed(2)
    def test_cox_stomp_send_receipt_id(self):
        m = Main()
        m.tcp_connect()
        tmpId = str(uuid.uuid4())
        m.send_connect([('receipt', tmpId)])
        (result, headers, body) = m.get_frame()
        for (name, value) in headers:
            if name == 'receipt-id':
                eq_(value, tmpId)
                return
        raise Exception('No receipt-id')
Polls for the specified job to finish running (successfully or not).
dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py/MainTests.test_cox_stomp_send_receipt_id--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py/DataflowPipelineRunner.poll_for_job_completion