summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-07-01 12:10:11 -0400
committerEvan Prodromou <evan@controlyourself.ca>2009-07-01 12:10:11 -0400
commit2325d934a8abfc611f455d4f0b816e2dd62c5ec4 (patch)
treecb5cdc016ed88c136d5dbfc5a2d6b9fe09be071b /lib
parent557418bc1e4e9d8a06025910ad7be5f60557f71e (diff)
add fail() method to stompqueuemanager
Diffstat (limited to 'lib')
-rw-r--r--lib/stompqueuemanager.php11
1 files changed, 11 insertions, 0 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 1b4a26f2e..badcd4abb 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;