X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Funqueuemanager.php;h=0540b767d218300c03c58bbfb603bd7b7dfc36f1;hb=349e842078c5d69901df6ec9205cf7edcb4c4636;hp=5595eac052c18baab2b1effe6879a3c5031fcfd6;hpb=108c51fa6859ec56269078ef9bd0459fdbd9b1ba;p=quix0rs-gnu-social.git

diff --git a/lib/unqueuemanager.php b/lib/unqueuemanager.php
index 5595eac052..0540b767d2 100644
--- a/lib/unqueuemanager.php
+++ b/lib/unqueuemanager.php
@@ -38,19 +38,17 @@ class UnQueueManager extends QueueManager
      * that can be processed quickly and don't need polling or long-running
      * connections to another server such as XMPP.
      *
-     * @param Notice $object
+     * @param Notice $object    this specific manager just handles Notice objects anyway
      * @param string $queue
      */
-    function enqueue($object, $queue)
+    function enqueue($object, $transport)
     {
-        $notice = $object;
-        
-        $handler = $this->getHandler($queue);
-        if ($handler) {
-            $handler->handle_notice($notice);
-        } else {
-            if (Event::handle('UnqueueHandleNotice', array(&$notice, $queue))) {
-                throw new ServerException("UnQueueManager: Unknown queue: $queue");
+        try {
+            $handler = $this->getHandler($transport);
+            $handler->handle($object);
+        } catch (NoQueueHandlerException $e) {
+            if (Event::handle('UnqueueHandleNotice', array(&$object, $transport))) {
+                throw new ServerException("UnQueueManager: Unknown queue transport: $transport");
             }
         }
     }