

def get_consumers(self, Consumer, channel):
    return [Consumer(queues=[rpc.nailgun_queue], callbacks=[self.consume_msg])]

dataset/ETHPy150Open openstack/fuel-web/nailgun/nailgun/rpc/receiverd.py RPCConsumer.get_consumers/original