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);
	}

	public function doWork() {
	$message = $this->loadMessage();
	if (!$message) {
	throw new PhabricatorWorkerPermanentFailureException(
	pht('Unable to load message!'));
	}

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

	$id = $message->getID();
	$message->sendNow();

	// task failed if the message is still queued
	// (instead of sent, void, or failed)
	if ($message->getStatus() == PhabricatorMetaMTAMail::STATUS_QUEUE) {
	throw new Exception(
	pht('Failed to send message.'));
	}
	}

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

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

	}