]> git.mxchange.org Git - quix0rs-gnu-social.git/commitdiff
add fail() method to stompqueuemanager
authorEvan Prodromou <evan@controlyourself.ca>
Wed, 1 Jul 2009 16:10:11 +0000 (12:10 -0400)
committerEvan Prodromou <evan@controlyourself.ca>
Wed, 1 Jul 2009 16:10:11 +0000 (12:10 -0400)
lib/stompqueuemanager.php

index 1b4a26f2ea6ab5fac5dee8da35fced8f2913f1e1..badcd4abb0fee788afc579b9940c85a7452f7da8 100644 (file)
@@ -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;