def METHOD_NAME(self):
    d = self.mq.waitUntilEvent(('abc',), lambda: False)
    self.assertEqual(d.called, False)
    self.mq.produce(('abc',), {"x": 1})
    self.assertEqual(d.called, True)
    res = yield d
    self.assertEqual(res, (('abc',), {"x": 1}))