detailed printout

Author: Alexey Tsitkin

eb_sqs/worker/service.py

@@ -76,8 +76,9 @@ def process_messages(self, queues, worker):
                     })
 
                 if len(messages) > 0:
-                    queue.delete_messages(Entries=msg_entries)
-                    logger.debug('[django-eb-sqs] Deleted {} messages'.format(len(messages)))
+                    response = queue.delete_messages(Entries=msg_entries)
+                    logger.debug('[django-eb-sqs] Deleted {} messages successfully'.format(len(response['Successful'])))
+                    logger.debug('[django-eb-sqs] Failed deleting {} messages'.format(len(response['Failed'])))
             except Exception as exc:
                 logger.warning('[django-eb-sqs] Error polling queue {}: {}'.format(queue.url, exc), exc_info=1)