manually re-enqueue failed notices

1 files changed, 4 insertions, 1 deletions

diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 06be2ba85..4cefba113 100644
--- 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);
                 }