

def test_functional_basic_get(self):
    payload = 'hello world'
    queue = 'test_functional_basic_get'
    try:
        self.channel.queue.declare(queue)
        self.channel.basic.publish(payload, queue)
        message = self.channel.basic.get(queue, to_dict=False)
        self.assertEqual(message.body, payload)
        message.ack()
    finally:
        self.channel.queue.delete(queue)

dataset/ETHPy150Open eandersson/amqpstorm/amqpstorm/tests/functional/basic_tests.py BasicFunctionalTests.test_functional_basic_get/original