diff options
author | Brion Vibber <brion@pobox.com> | 2010-01-27 17:39:03 -0800 |
---|---|---|
committer | Brion Vibber <brion@pobox.com> | 2010-01-27 17:39:03 -0800 |
commit | 0794ecf372ffff2e0cc93509ae3462ca0cbbc99c (patch) | |
tree | 79695c758dc0e919b5cbcaaf1260125f3e97c4a2 /lib/queuemanager.php | |
parent | 2e0297bb6ff0fd2d3a37d811bd3305ce5d6a77ee (diff) | |
parent | 07d50a012af70d9bd35a26f645d791ae7ba29986 (diff) |
Merge branch 'testing' of gitorious.org:statusnet/mainline
Diffstat (limited to 'lib/queuemanager.php')
-rw-r--r-- | lib/queuemanager.php | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/lib/queuemanager.php b/lib/queuemanager.php index e5cf8239e..afe710e88 100644 --- a/lib/queuemanager.php +++ b/lib/queuemanager.php @@ -101,6 +101,23 @@ abstract class QueueManager extends IoManager } /** + * Optional; ping any running queue handler daemons with a notification + * such as announcing a new site to handle or requesting clean shutdown. + * This avoids having to restart all the daemons manually to update configs + * and such. + * + * Called from scripts/queuectl.php controller utility. + * + * @param string $event event key + * @param string $param optional parameter to append to key + * @return boolean success + */ + public function sendControlSignal($event, $param='') + { + throw new Exception(get_class($this) . " does not support control signals."); + } + + /** * Store an object (usually/always a Notice) into the given queue * for later processing. No guarantee is made on when it will be * processed; it could be immediately or at some unspecified point @@ -225,7 +242,6 @@ abstract class QueueManager extends IoManager // XMPP output handlers... $this->connect('jabber', 'JabberQueueHandler'); $this->connect('public', 'PublicQueueHandler'); - // @fixme this should get an actual queue //$this->connect('confirm', 'XmppConfirmHandler'); |