def test_topic_send_receive(self):

        conn = self.rpc.create_connection()
        message = 'topic test message'

        self.received_message = None

        def _callback(message):
            self.received_message = message

        conn.declare_topic_consumer('a_topic', _callback)
        conn.topic_send('a_topic', message)
        conn.consume(limit=1)
        conn.close()

        self.assertEqual(self.received_message, message)
Handles checking if the user should be throttled.
dataset/ETHPy150Open nii-cloud/dodai-compute/nova/tests/test_rpc_kombu.py/RpcKombuTestCase.test_topic_send_receive--crossover with--dataset/ETHPy150Open toastdriven/piecrust/piecrust/resources.py/Resource.throttle_check