GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

StompQueueManager uses decode() to decode queued frames

Browse Source
This commit is contained in:
Craig Andrews 2010-01-22 18:02:05 -05:00
parent b157fcbba3
commit 845f051c2f
1 changed files with 1 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
lib/stompqueuemanager.php
View File

@ -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) {