Changeset View
Changeset View
Standalone View
Standalone View
src/applications/feed/worker/FeedPublisherHTTPWorker.php
| Show All 20 Lines | $post_data = array( | ||||
| 'storyID' => $data->getID(), | 'storyID' => $data->getID(), | ||||
| 'storyType' => $data->getStoryType(), | 'storyType' => $data->getStoryType(), | ||||
| 'storyData' => $data->getStoryData(), | 'storyData' => $data->getStoryData(), | ||||
| 'storyAuthorPHID' => $data->getAuthorPHID(), | 'storyAuthorPHID' => $data->getAuthorPHID(), | ||||
| 'storyText' => $story->renderText(), | 'storyText' => $story->renderText(), | ||||
| 'epoch' => $data->getEpoch(), | 'epoch' => $data->getEpoch(), | ||||
| ); | ); | ||||
| // NOTE: We're explicitly using "http_build_query()" here because the | |||||
| // "storyData" parameter may be a nested object with arbitrary nested | |||||
| // sub-objects. | |||||
| $post_data = http_build_query($post_data, '', '&'); | |||||
| id(new HTTPSFuture($uri, $post_data)) | id(new HTTPSFuture($uri, $post_data)) | ||||
| ->setMethod('POST') | ->setMethod('POST') | ||||
| ->setTimeout(30) | ->setTimeout(30) | ||||
| ->resolvex(); | ->resolvex(); | ||||
| } | } | ||||
| public function getWaitBeforeRetry(PhabricatorWorkerTask $task) { | public function getWaitBeforeRetry(PhabricatorWorkerTask $task) { | ||||
| return max($task->getFailureCount(), 1) * 60; | return max($task->getFailureCount(), 1) * 60; | ||||
| } | } | ||||
| } | } | ||||