From: Evan Prodromou <evan@controlyourself.ca>
Date: Wed, 8 Jul 2009 05:36:12 +0000 (-0400)
Subject: log errors in handling notices
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=a626f32d8e01faa620a11e1f8370a35cc660a579;p=quix0rs-gnu-social.git

log errors in handling notices
---

diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index e7e1e00dd9..06be2ba850 100644
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -100,11 +100,16 @@ class StompQueueManager
                 $notice = Notice::staticGet('id', $frame->body);
 
                 if (empty($notice)) {
-                    $this->_log(LOG_WARNING, 'Got ID '. $frame->body .' for non-existent notice');
-                    $this->con->ack($frame);
-                } else if ($handler->handle_notice($notice)) {
-                    $this->_log(LOG_INFO, 'Successfully handled notice '. $notice->id .' posted at ' . $frame->headers['created']);
+                    $this->_log(LOG_WARNING, 'Got ID '. $frame->body .' for non-existent notice in queue '. $queue);
                     $this->con->ack($frame);
+                } else {
+                    if ($handler->handle_notice($notice)) {
+                        $this->_log(LOG_INFO, 'Successfully handled notice '. $notice->id .' posted at ' . $frame->headers['created'] . ' in queue '. $queue);
+                        $this->con->ack($frame);
+                    } else {
+                        $this->_log(LOG_WARNING, 'Failed handling notice '. $notice->id .' posted at ' . $frame->headers['created']  . ' in queue '. $queue);
+                        // Don't ack; it'll get re-sent
+                    }
                     unset($notice);
                 }