{"action":"created","issue":{"url":"https://api.github.com/repos/gmr/rabbitpy/issues/71","labels_url":"https://api.github.com/repos/gmr/rabbitpy/issues/71/labels{/name}","comments_url":"https://api.github.com/repos/gmr/rabbitpy/issues/71/comments","events_url":"https://api.github.com/repos/gmr/rabbitpy/issues/71/events","html_url":"https://github.com/gmr/rabbitpy/issues/71","id":73972788,"number":71,"title":"Queue left dangling after RabbitMQ crash","user":{"login":"dubmartin","id":358497,"avatar_url":"https://avatars.githubusercontent.com/u/358497?v=3","gravatar_id":"","url":"https://api.github.com/users/dubmartin","html_url":"https://github.com/dubmartin","followers_url":"https://api.github.com/users/dubmartin/followers","following_url":"https://api.github.com/users/dubmartin/following{/other_user}","gists_url":"https://api.github.com/users/dubmartin/gists{/gist_id}","starred_url":"https://api.github.com/users/dubmartin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dubmartin/subscriptions","organizations_url":"https://api.github.com/users/dubmartin/orgs","repos_url":"https://api.github.com/users/dubmartin/repos","events_url":"https://api.github.com/users/dubmartin/events{/privacy}","received_events_url":"https://api.github.com/users/dubmartin/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-05-07T12:40:02Z","updated_at":"2015-05-07T12:50:16Z","closed_at":null,"body":"I have a simple queue connection to listen to new messages\r\n\r\n```\r\nwith rabbitpy.Connection(RABBIT_MQ_CONN) as conn:\r\n\twith conn.channel() as channel:\r\n\t\tqueue = self.setupQueue(channel)\r\n\r\n\t\tfor message in queue:\r\n\t\t\t....\r\n```\r\n\r\nThis is contained in a method that is within a\r\n\r\n```\r\nwhile True:\r\n    try:\r\n        self.Consume()\r\n    except Exception e:\r\n        log()\r\n\r\n\r\nWhen the rabbitmq server stops / crashes / restarted the queue is left dangling and new receives any new messages.\r\n\r\nI have a similar issue with a c# .net library, but they had a timeout value on the \r\n```\r\nqueue.Dequeue(timeout)\r\n```\r\n\r\nI have tried to find something similar in rabbitpy but cannot. Probably I am not seeing what is right in front of me, but any help / advice appreciated\r\n\r\n\r\ncheers"},"comment":{"url":"https://api.github.com/repos/gmr/rabbitpy/issues/comments/99852285","html_url":"https://github.com/gmr/rabbitpy/issues/71#issuecomment-99852285","issue_url":"https://api.github.com/repos/gmr/rabbitpy/issues/71","id":99852285,"user":{"login":"dubmartin","id":358497,"avatar_url":"https://avatars.githubusercontent.com/u/358497?v=3","gravatar_id":"","url":"https://api.github.com/users/dubmartin","html_url":"https://github.com/dubmartin","followers_url":"https://api.github.com/users/dubmartin/followers","following_url":"https://api.github.com/users/dubmartin/following{/other_user}","gists_url":"https://api.github.com/users/dubmartin/gists{/gist_id}","starred_url":"https://api.github.com/users/dubmartin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dubmartin/subscriptions","organizations_url":"https://api.github.com/users/dubmartin/orgs","repos_url":"https://api.github.com/users/dubmartin/repos","events_url":"https://api.github.com/users/dubmartin/events{/privacy}","received_events_url":"https://api.github.com/users/dubmartin/received_events","type":"User","site_admin":false},"created_at":"2015-05-07T12:50:16Z","updated_at":"2015-05-07T12:50:16Z","body":"Actually I think I may be on an old code base, I will check if I am update"}}