From: Evan Prodromou Date: Wed, 8 Jul 2009 21:55:43 +0000 (-0400) Subject: manually re-enqueue failed notices X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=8aef0e4271dda4210901de635b4227e6dbefca18;p=quix0rs-gnu-social.git manually re-enqueue failed notices --- diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php index 06be2ba850..4cefba1132 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); }