for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/******************************************************************************
* Copyright (c) 2016 Constantin Galbenu <[email protected]> *
******************************************************************************/
namespace Gica\Cqrs\Scheduling;
use Gica\Cqrs\Command\CommandDispatcher;
use Gica\Cqrs\ScheduledCommandStore;
class ScheduledCommandsDispatcher
{
/**
* @var ScheduledCommandStore
*/
private $store;
* @var CommandDispatcher
private $dispatcher;
public function __construct(
ScheduledCommandStore $store,
CommandDispatcher $dispatcher
)
$this->store = $store;
$this->dispatcher = $dispatcher;
}
public function run()
$this->store->loadAndProcessScheduledCommands(function (ScheduledCommand $scheduledCommand) {
$this->dispatcher->dispatchCommand($scheduledCommand);
});
xprt64 /
cqrs-es
