add fail() method to stompqueuemanager

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;