@task_manager.require_exclusive_lock
    def set_power_state(self, task, power_state):
        _set_power_state(task, power_state)
Test sending to a topic exchange/queue
dataset/ETHPy150Open openstack/ironic/ironic/drivers/modules/irmc/power.py/IRMCPower.set_power_state--crossover with--dataset/ETHPy150Open nii-cloud/dodai-compute/nova/tests/test_rpc_kombu.py/RpcKombuTestCase.test_topic_send_receive