X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Fqueuemanager.php;h=45fe1e4ab43040343989833046206622bfc2f72b;hb=b24d711f552854d88f2df2120672bdaf173335fc;hp=1fb6c3eb45db88db6ac7ccff48f6e08de1936efa;hpb=9400795a5f4d5aa8b46c82cd7b021330d1f10e3a;p=quix0rs-gnu-social.git

diff --git a/lib/queuemanager.php b/lib/queuemanager.php
index 1fb6c3eb45..45fe1e4ab4 100644
--- a/lib/queuemanager.php
+++ b/lib/queuemanager.php
@@ -67,9 +67,6 @@ abstract class QueueManager extends IoManager
                     self::$qm = new UnQueueManager();
                 } else {
                     switch ($type) {
-                     case 'opportunistic':
-                        self::$qm = new OpportunisticQueueManager();
-                        break;
                      case 'db':
                         self::$qm = new DBQueueManager();
                         break;
@@ -183,7 +180,11 @@ abstract class QueueManager extends IoManager
         $object = unserialize($frame);
 
         // If it is a string, we really store a JSON object in there
-        if (is_string($object)) {
+        // except if it begins with '<', because then it is XML.
+        if (is_string($object) &&
+            substr($object, 0, 1) != '<' &&
+            !is_numeric($object))
+        {
             $json = json_decode($object);
             if ($json === null) {
                 throw new Exception('Bad frame in queue item');
@@ -232,8 +233,6 @@ abstract class QueueManager extends IoManager
             } else {
                 $this->_log(LOG_ERR, "Nonexistent handler class '$class' for queue '$queue'");
             }
-        } else {
-            $this->_log(LOG_ERR, "Requested handler for unkown queue '$queue'");
         }
         return null;
     }