summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-07-08 17:55:43 -0400
committerEvan Prodromou <evan@controlyourself.ca>2009-07-08 17:55:43 -0400
commit8aef0e4271dda4210901de635b4227e6dbefca18 (patch)
tree69ce88903f957b31003f782e995c8dc2f9392593
parent8bdb7dc93c9f5f5c4befa2ce3891e4d2f2826dbf (diff)
manually re-enqueue failed notices
-rw-r--r--lib/stompqueuemanager.php5
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);
}