

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

dataset/ETHPy150Open slimta/python-slimta/test/test_slimta_queue.py TestQueue.test_enqueue_wait/VarMisuse@92/109 `queue`->`self`