for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace PSB\Persistence\Doctrine2\Outbox;
use PSB\Core\BusContextInterface;
use PSB\Core\Feature\FeatureStartupTaskInterface;
use PSB\Core\Util\Settings;
use PSB\Persistence\Doctrine2\Doctrine2KnownSettingsEnum;
class EndpointIdLoaderFeatureStartupTask implements FeatureStartupTaskInterface
{
/**
* @var OutboxPersister
*/
private $outboxPersister;
* @var Settings
private $settings;
* @var string
private $endpointName;
* @param OutboxPersister $outboxPersister
* @param Settings $settings
* @param string $endpointName
public function __construct(OutboxPersister $outboxPersister, Settings $settings, $endpointName)
$this->outboxPersister = $outboxPersister;
$this->settings = $settings;
$this->endpointName = $endpointName;
}
* @param BusContextInterface $busContext
public function start(BusContextInterface $busContext)
$endpointId = $this->outboxPersister->fetchOrGenerateEndpointId($this->endpointName);
$this->settings->set(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINT_ID, $endpointId);