. */ if (!defined('STATUSNET')) { exit(1); } /** * Renew an expiring feedsub * @package FeedSub * @author Stephen Paul Weber */ class PushRenewQueueHandler extends QueueHandler { function transport() { return 'pushrenew'; } function handle($data) { $feedsub_id = $data['feedsub_id']; $feedsub = FeedSub::getKV('id', $feedsub_id); if ($feedsub instanceof FeedSub) { try { common_log(LOG_INFO, "Renewing feed subscription\n\tExp.: {$feedsub->sub_end}\n\tFeed: {$feedsub->uri}\n\tHub: {$feedsub->huburi}"); $feedsub->renew(); } catch(Exception $e) { common_log(LOG_ERR, "Exception during PuSH renew processing for $feedsub->uri: " . $e->getMessage()); } } else { common_log(LOG_ERR, "Discarding renew for unknown feed subscription id $feedsub_id"); } return true; } }