Differential D8115 Diff 18380 src/applications/metamta/management/PhabricatorMailManagementResendWorkflow.php
Changeset View
Changeset View
Standalone View
Standalone View
src/applications/metamta/management/PhabricatorMailManagementResendWorkflow.php
| Show First 20 Lines • Show All 48 Lines • ▼ Show 20 Lines | foreach ($messages as $message) { | ||||
| $console->writeOut( | $console->writeOut( | ||||
| "Message #%d is already queued with an assigned send task.\n", | "Message #%d is already queued with an assigned send task.\n", | ||||
| $message->getID()); | $message->getID()); | ||||
| continue; | continue; | ||||
| } | } | ||||
| } | } | ||||
| $message->setStatus(PhabricatorMetaMTAMail::STATUS_QUEUE); | $message->setStatus(PhabricatorMetaMTAMail::STATUS_QUEUE); | ||||
| $message->setRetryCount(0); | |||||
| $message->setNextRetry(time()); | |||||
| $message->save(); | $message->save(); | ||||
| $mailer_task = PhabricatorWorker::scheduleTask( | $mailer_task = PhabricatorWorker::scheduleTask( | ||||
| 'PhabricatorMetaMTAWorker', | 'PhabricatorMetaMTAWorker', | ||||
| $message->getID()); | $message->getID()); | ||||
| $message->setWorkerTaskID($mailer_task->getID()); | $message->setWorkerTaskID($mailer_task->getID()); | ||||
| $message->save(); | $message->save(); | ||||
| $console->writeOut( | $console->writeOut( | ||||
| "Queued message #%d for resend.\n", | "Queued message #%d for resend.\n", | ||||
| $message->getID()); | $message->getID()); | ||||
| } | } | ||||
| } | } | ||||
| } | } | ||||