From 2325d934a8abfc611f455d4f0b816e2dd62c5ec4 Mon Sep 17 00:00:00 2001 From: Evan Prodromou Date: Wed, 1 Jul 2009 12:10:11 -0400 Subject: [PATCH] add fail() method to stompqueuemanager --- lib/stompqueuemanager.php | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php index 1b4a26f2ea..badcd4abb0 100644 --- a/lib/stompqueuemanager.php +++ b/lib/stompqueuemanager.php @@ -126,6 +126,17 @@ class StompQueueManager } } + function fail($object, $queue) + { + $notice = $object; + + // STOMP server will requeue it after a while anyways, + // so no need to notify. Just get it out of our little + // array + + $this->_clearFrame($notice, $queue); + } + function _frameKey($notice, $queue) { return ((string)$notice->id) . '-' . $queue;