From: Evan Prodromou <evan@controlyourself.ca>
Date: Wed, 1 Jul 2009 16:10:11 +0000 (-0400)
Subject: add fail() method to stompqueuemanager
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=2325d934a8abfc611f455d4f0b816e2dd62c5ec4;p=quix0rs-gnu-social.git

add fail() method to stompqueuemanager
---

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;