PhabricatorMetaMTAWorker.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	final class PhabricatorMetaMTAWorker
	extends PhabricatorWorker {

	public function getMaximumRetryCount() {
	return 250;
	}

	public function getWaitBeforeRetry(PhabricatorWorkerTask $task) {
	return ($task->getFailureCount() * 15);
	}

	protected function doWork() {
	$message = $this->loadMessage();

	if ($message->getStatus() != PhabricatorMailOutboundStatus::STATUS_QUEUE) {
	return;
	}

	try {
	$message->sendNow();
	} catch (PhabricatorMetaMTAPermanentFailureException $ex) {
	// If the mailer fails permanently, fail this task permanently.
	throw new PhabricatorWorkerPermanentFailureException($ex->getMessage());
	}
	}

	private function loadMessage() {
	$message_id = $this->getTaskData();
	$message = id(new PhabricatorMetaMTAMail())
	->load($message_id);

	if (!$message) {
	throw new PhabricatorWorkerPermanentFailureException(
	pht(
	'Unable to load mail message (with ID "%s") while preparing to '.
	'deliver it.',
	$message_id));
	}

	return $message;
	}

	public function renderForDisplay(PhabricatorUser $viewer) {
	return phutil_tag(
	'pre',
	array(
	),
	'phabricator/ $ ./bin/mail show-outbound --id '.$this->getTaskData());
	}

	}