summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorCraig Andrews <candrews@integralblue.com>2010-01-22 18:02:05 -0500
committerCraig Andrews <candrews@integralblue.com>2010-01-22 18:02:05 -0500
commit845f051c2f85248ef85d0a34f032792ca83f04a4 (patch)
tree39ca7fdd37788ad273b139c655f9ce9e8f3dbbd4 /lib
parentb157fcbba3c4c105945d18dfa11732ba02e7222b (diff)
StompQueueManager uses decode() to decode queued frames
Diffstat (limited to 'lib')
-rw-r--r--lib/stompqueuemanager.php21
1 files changed, 1 insertions, 20 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 8f0091a13..4bbdeedc2 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) {