phorge-phorge/src/applications/metamta/PhabricatorMetaMTAWorker.php

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

}