

def test_enqueue_wait_norelay(self):
    self.store.write(self.env, IsA(float)).AndReturn('1234')
    self.mox.ReplayAll()
    queue = Queue(self.store, relay_pool=5)
    self.assertEqual([(self.env, '1234')], queue.enqueue(self.env))
    queue.relay_pool.join()

dataset/ETHPy150Open slimta/python-slimta/test/test_slimta_queue.py TestQueue.test_enqueue_wait_norelay/original