From: Craig Andrews <candrews@integralblue.com>
Date: Fri, 22 Jan 2010 23:02:05 +0000 (-0500)
Subject: StompQueueManager uses decode() to decode queued frames
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=845f051c2f85248ef85d0a34f032792ca83f04a4;p=quix0rs-gnu-social.git

StompQueueManager uses decode() to decode queued frames
---

diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 8f0091a138..4bbdeedc20 100644
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -294,26 +294,7 @@ class StompQueueManager extends QueueManager
             StatusNet::init($site);
         }
 
-        if (is_numeric($frame->body)) {
-            $id = intval($frame->body);
-            $info = "notice $id posted at {$frame->headers['created']} in queue $queue";
-
-            $notice = Notice::staticGet('id', $id);
-            if (empty($notice)) {
-                $this->_log(LOG_WARNING, "Skipping missing $info");
-                $this->ack($frame);
-                $this->commit();
-                $this->begin();
-                $this->stats('badnotice', $queue);
-                return false;
-            }
-
-            $item = $notice;
-        } else {
-            // @fixme should we serialize, or json, or what here?
-            $info = "string posted at {$frame->headers['created']} in queue $queue";
-            $item = $frame->body;
-        }
+        $item = $this->decode($frame->body);
 
         $handler = $this->getHandler($queue);
         if (!$handler) {