manually re-enqueue failed notices

2009-07-08 17:55:43 -04:00 · 2009-07-08 17:55:43 -04:00 · 8aef0e4271
commit 8aef0e4271
parent 8bdb7dc93c
1 changed files with 4 additions and 1 deletions
--- 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);
                }