gistfile1.txt

λ ~/Development/RabbitMQ/debug/ python server-216.py
connecting ...
setting up ...
publishing ...
fetched message: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 7, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 1, 'headers': {'x-puka-delivery-tag': 4, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen2-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen2-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen1-test.issue_216_crashing_queue'], 'queue': 'toq-gen1-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}]}, 'redelivered': False, 'delivery_tag': 1}
declaring timeout queue toq-gen3-test.issue_216_crashing_queue
publishing to toq-gen3-test.issue_216_crashing_queue: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 7, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 1, 'headers': {'x-puka-delivery-tag': 4, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen2-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen2-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen1-test.issue_216_crashing_queue'], 'queue': 'toq-gen1-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}]}, 'redelivered': False, 'delivery_tag': 1}
fetched message: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 10, 'routing_key': 'test.issue_216', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 1}, 'redelivered': False, 'delivery_tag': 2}
declaring timeout queue toq-gen0-test.issue_216_crashing_queue
publishing to toq-gen0-test.issue_216_crashing_queue: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 10, 'routing_key': 'test.issue_216', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 1}, 'redelivered': False, 'delivery_tag': 2}
fetched message: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 13, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 2, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 59), 'queue': 'toq-gen3-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen3-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen1-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen1-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue'], 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen2-test.issue_216_crashing_queue'], 'queue': 'toq-gen2-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}]}, 'redelivered': False, 'delivery_tag': 3}
declaring timeout queue toq-gen4-test.issue_216_crashing_queue
publishing to toq-gen4-test.issue_216_crashing_queue: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 13, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 2, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 59), 'queue': 'toq-gen3-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen3-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47), 'queue': 'toq-gen1-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen1-test.issue_216_crashing_queue']}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue'], 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}, {'count': 1, 'exchange': '', 'routing-keys': ['toq-gen2-test.issue_216_crashing_queue'], 'queue': 'toq-gen2-test.issue_216_crashing_queue', 'reason': 'expired', 'time': datetime.datetime(2015, 7, 8, 10, 30, 47)}]}, 'redelivered': False, 'delivery_tag': 3}
fetched message: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 16, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 3, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 59), 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue']}]}, 'redelivered': False, 'delivery_tag': 4}
declaring timeout queue toq-gen1-test.issue_216_crashing_queue
publishing to toq-gen1-test.issue_216_crashing_queue: {'body': 'foo', 'exchange': 'amq.topic', 'promise_number': 16, 'routing_key': 'test.issue_216_crashing_queue', 'message_count': 0, 'headers': {'x-puka-delivery-tag': 3, 'x-death': [{'count': 1L, 'exchange': '', 'time': datetime.datetime(2015, 7, 8, 10, 30, 59), 'queue': 'toq-gen0-test.issue_216_crashing_queue', 'reason': 'expired', 'routing-keys': ['toq-gen0-test.issue_216_crashing_queue']}]}, 'redelivered': False, 'delivery_tag': 4}
fetched message: {'cluster_id': '', 'empty': True}