Git-Mirrors/brozzler
1
0
Fork 0
mirror of https://github.com/internetarchive/brozzler.git synced 2025-02-23 16:19:49 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #29 from nlevitt/handle-bad-message

Browse Source 
reject (discard) bad messages
This commit is contained in:
vonrosen 2014-08-20 08:21:29 -07:00
commit bbba344886
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
umbra/controller.py
View File

@ -98,7 +98,17 @@ class AmqpBrowserController:
browser.start()
def callback(body, message):
self._start_browsing_page(browser, message, body['clientId'], body['url'], body['metadata'])
try:
client_id, url, metadata = body['clientId'], body['url'], body['metadata']
except:
self.logger.error("unable to decipher message {}".format(message), exc_info=True)
self.logger.error("discarding bad message")
message.reject()
browser.stop()
self._browser_pool.release(browser)
return
self._start_browsing_page(browser, message, client_id, url, metadata)
consumer.callbacks = [callback]
while True: