Pull out the 'tweetctl' queue for now; these should go over control signals, and actual handling isn't implemented yet anyway.
This commit is contained in:
parent
a2f0f68d75
commit
9cbda32768
@ -279,9 +279,6 @@ class TwitterBridgePlugin extends Plugin
|
||||
|
||||
// Incoming statuses <- twitter
|
||||
$manager->connect('tweetin', 'TweetInQueueHandler');
|
||||
|
||||
// Control messages from our web interface to the import daemon
|
||||
$manager->connect('tweetctl', 'TweetCtlQueueHandler', 'twitter');
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
@ -285,7 +285,7 @@ class TwittersettingsAction extends ConnectSettingsAction
|
||||
}
|
||||
|
||||
$original = clone($flink);
|
||||
$wasReceiving = (bool)($original->notice_sync & FOREIGN_NOTICE_RECV);
|
||||
$wasReceiving = (bool)($original->noticesync & FOREIGN_NOTICE_RECV);
|
||||
$flink->set_flags($noticesend, $noticerecv, $replysync, $friendsync);
|
||||
$result = $flink->update($original);
|
||||
|
||||
@ -307,10 +307,7 @@ class TwittersettingsAction extends ConnectSettingsAction
|
||||
*/
|
||||
function notifyDaemon($twitterUserId, $receiving)
|
||||
{
|
||||
$data = array('for_user' => $twitterUserId,
|
||||
'action' => $receiving ? 'stop' : 'start');
|
||||
$qm = QueueManager::get();
|
||||
$qm->enqueue($data, 'twitterctl');
|
||||
// todo... should use control signals rather than queues
|
||||
}
|
||||
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user