manually re-enqueue failed notices

diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 06be2ba850077611bb978f001a4bb45ff4ef32e6..4cefba1132d5f99cdd8739de9cb2e084c9451d0b 100644 (file)
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -108,7 +108,10 @@ class StompQueueManager
                         $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
+                        // FIXME we probably shouldn't have to do
+                        // this kind of queue management ourselves
+                        $this->con->ack($frame);
+                        $this->enqueue($notice, $queue);
                     }
                     unset($notice);
                 }