x/stacktach
Code Issues Proposed changes

Merge pull request #281 from TelekomLabs/log_decode_errors

Browse Source 
log decode errors, do not ack.
This commit is contained in:
anujm 2014-03-14 15:56:43 +05:30
commit 9d1a93a49e
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
worker/worker.py
View File

@ -150,6 +150,10 @@ class Consumer(kombu.mixins.ConsumerMixin):
_get_child_logger().error("RabbitMQ Broker connection error: %r. " _get_child_logger().error("RabbitMQ Broker connection error: %r. "
"Trying again in %s seconds.", exc, interval) "Trying again in %s seconds.", exc, interval)
def on_decode_error(self, message, exc):
_get_child_logger().exception("Decode Error: %s" % exc)
# do NOT call message.ack(), otherwise the message will be lost
def continue_running(): def continue_running():
return not shutdown_soon return not shutdown_soon