def METHOD_NAME(self):
    cb = mock.Mock()
    qref = yield self.mq.startConsuming(cb, ('abc',))
    cb2 = mock.Mock()
    qref2 = yield self.mq.startConsuming(cb2, ('abc',))
    qref.stopConsuming()
    self.mq.produce(('abc',), '{}')
    qref = yield self.mq.startConsuming(cb, ('abc',))
    qref.stopConsuming()
    qref2.stopConsuming()
    self.assertTrue(cb2.called)
    self.assertFalse(cb.called)