Temporal is a distributed, scalable, durable, and highly available orchestration engine used to execute asynchronous long-running business logic in a scalable and resilient way.
Read more at official website.
RoadRunner >= 2.0 includes a plugin to execute Temporal workflows and activities. Make sure to write temporal worker.
Activate plugin via config:
rpc:
listen: tcp://127.0.0.1:6001
server:
command: "php worker.php"
temporal:
address: "127.0.0.1:7233"
activities:
num_workers: 10
logs:
level: debug
channels:
temporal.level: error
Integrated workflow server provides the ability to create very complex, long-running activities.
class SubscriptionWorkflow implements SubscriptionWorkflowInterface
{
private $account;
public function __construct()
{
$this->account = Workflow::newActivityStub(
AccountActivityInterface::class,
ActivityOptions::new()
->withScheduleToCloseTimeout(DateInterval::createFromDateString('2 seconds'))
);
}
public function subscribe(string $userID)
{
yield $this->account->sendWelcomeEmail($userID);
try {
$trialPeriod = true;
while (true) {
// Lower period duration to observe workflow behavior
yield Workflow::timer(DateInterval::createFromDateString('30 days'));
yield $this->account->chargeMonthlyFee($userID);
if ($trialPeriod) {
yield $this->account->sendEndOfTrialEmail($userID);
$trialPeriod = false;
continue;
}
yield $this->account->sendMonthlyChargeEmail($userID);
}
} catch (CanceledFailure $e) {
yield Workflow::asyncDetached(
function () use ($userID) {
yield $this->account->processSubscriptionCancellation($userID);
yield $this->account->sendSorryToSeeYouGoEmail($userID);
}
);
}
}
}
Read more at official website.