From 8aef0e4271dda4210901de635b4227e6dbefca18 Mon Sep 17 00:00:00 2001 From: Evan Prodromou Date: Wed, 8 Jul 2009 17:55:43 -0400 Subject: manually re-enqueue failed notices --- lib/stompqueuemanager.php | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'lib') 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); } -- cgit v1.2.3-54-g00ecf