Function Index
$#! · 0-9 · A · B · C · D · E · F · G · H · I · J · K · L · M · N · O · P · Q · R · S · T · U · V · W · X · Y · Z
$#!
 __construct
 _addCollection, ActivitySink
 _child, Activity
 _childContent, ActivityObject
 _connect, StompQueueManager
 _connectAll, StompQueueManager
 _doConnect, StompQueueManager
 _doEnqueue, StompQueueManager
 _done, DBQueueManager
 _fail, DBQueueManager
 _fromAtomEntry
 _fromAuthor, ActivityObject
 _fromRssItem
 _getSource, ActivityObject
 _log, QueueManager
 _makeConnection, LiberalStomp
 _parseSvcDoc, ActivitySink
 _reconnect, StompQueueManager
 _writeFrame, LiberalStomp
A
 ack, StompQueueManager
 addItemFromNotice
 addItemsFromNotices
 addLink
 addNew, Deleted_notice
 age, RedisQueueItem
 asActivityObject, Deleted_notice
 asArray
 asString
B
 beforeSchemaUpdate
 begin, StompQueueManager
 breakoutMode, StompQueueManager
 byProfile, Avatar
function __construct($entry =  null,
$feed =  null)
Turns a regular old Atom entry into a magical activity
function __construct($element =  null)
Class constructor
function __construct($element =  null)
Class constructor
function __construct($svcDocUrl,
$username,
$password)
Constructor for the class object
function __construct($url =  null,
$rel =  null,
$mediaType =  null)
Class constructor
function __construct( $url =  null,
 $width =  null,
 $height =  null,
 $mediaType =  null,
// extension $rel =  null,
// extension $duration =  null)
Class constructor
function __construct($filename)
Class constructor.
function __construct($imPlugin)
function __construct($plugin)
Class constructor
function __construct($plugin)
Class constructor
function __construct($plugin)
function __construct($id =  null,
$interval =  60,
$max_children =  2,
$debug =  null)
Constructor
function __construct()
Constructor procedure
public function __construct($item,  
$created =  null)
Constructor for the class
function __construct($redis,
$name)
Class constructor
function __construct($address,
$namespace,
$expiration)
Class constructor
public function __construct($id,  
$tries,  
$created,  
$item,  
$processing_id_count =  0)
Class constructor
public function __construct($processing_id_count)
Exception class constructor
function __construct(Profile $scoped = null)
Class constructor
function __construct($id = null,
$daemonize = true,
$threads = 1)
Class constructor
function __construct()
Class constructor
private function _addCollection($verb,
$url)
private function _child($element,  
$tag,  
$namespace = self::SPEC)
Easy creation of a child class
private function _childContent($element,  
$tag,  
$namespace = ActivityUtils::ATOM)
protected function _connect()
Lazy open a single connection to Stomp queue server.
protected function _connectAll()
Lazy open connections to all Stomp servers, if in manual failover mode.
protected function _doConnect($server)
Handles connecting to a single STOMP server
protected function _doEnqueue($object,  
$queue,  
$idx,  
$siteNickname = null)
Saves a notice object reference into the queue item table on the given connection.
protected function _done(Queue_item $qi)
Delete our claimed item from the queue after successful processing.
protected function _fail(Queue_item $qi,  
 $releaseOnly = false)
Free our claimed queue item for later reprocessing in case of temporary failure.
function _fromAtomEntry($entry,
$feed)
private function _fromAtomEntry($element)
Create an activity object given an element
private function _fromAuthor($element)
Create an activity object given an element
function _fromRssItem($item,
$channel)
private function _fromRssItem($item)
Create an activity object from a RSS item
private function _getSource($element)
Try to get a unique id for the source feed
protected function _log($level,
$msg)
Log a string to the common log
protected function _makeConnection ()
Make socket connection to the server We also set the stream to non-blocking mode, since we’ll be select’ing to wait for updates.
private function _parseSvcDoc()
protected function _reconnect($idx)
Attempt to manually reconnect to the STOMP server for the given slot.
protected function _writeFrame (StompFrame $stompFrame)
Write frame to server
protected function ack($idx,
$frame)
function addItemFromNotice($notice)
Add a single Notice to the document
function addItemsFromNotices($notices)
Add more than one Item to the document
function addLink($url =  null,
$rel =  null,
$mediaType =  null)
Add a link to the JSON document
public static function addNew(Notice $notice,  
Profile $actor = null)
Add a new deleted notice to the database
public function age($now =  null)
How old is this queue item?
public function asActivityObject(Profile $scoped = null)
Returns the deletion notice as an ActivityObject, much like the name implies.
function asArray()
Returns an array based on this activity suitable for encoding as a JSON object
function asArray()
Returns context (StatusNet stuff) as an array suitable for serializing in JSON.
function asArray()
Returns an array based on this Activity Object suitable for encoding as JSON.
function asArray()
Return the link dictionary as an array
function asArray()
Return the class as an array suitable for JSON
function asString()
Return the entire document as a big string of JSON
function asString($namespace = false,
$author = true,
$source = false)
function asString($tag = 'activity:object')
Returns the ActivityObject as an XML string
static public function beforeSchemaUpdate()
Cleanup to do prior to database schema checks.
static public function beforeSchemaUpdate()
A variety of cleaning tasks to do before database integrity checks.
protected function begin($idx)
protected function breakoutMode($queue)
Get the breakout mode for the given queue on the current site.
public static function byProfile(Profile $target,  
 $width = null,
 $height = null)
Get an avatar by profile.