From e10b0025d88ceddc1bb95a885c430501f724ebe5 Mon Sep 17 00:00:00 2001 From: Max Date: Tue, 30 Aug 2022 18:23:15 +0300 Subject: [PATCH] Allow user to extend initialization --- src/Bootloader/TemporalBridgeBootloader.php | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/Bootloader/TemporalBridgeBootloader.php b/src/Bootloader/TemporalBridgeBootloader.php index e425dba..cd6bbe5 100644 --- a/src/Bootloader/TemporalBridgeBootloader.php +++ b/src/Bootloader/TemporalBridgeBootloader.php @@ -81,7 +81,7 @@ public function addWorkerOptions(string $worker, WorkerOptions $options): void $this->config->modify(TemporalConfig::CONFIG, new Append('workers', $worker, $options)); } - private function initWorkflowPresetLocator( + protected function initWorkflowPresetLocator( FactoryInterface $factory, ClassesInterface $classes ): WorkflowPresetLocatorInterface { @@ -92,7 +92,7 @@ private function initWorkflowPresetLocator( ); } - private function initConfig(EnvironmentInterface $env): void + protected function initConfig(EnvironmentInterface $env): void { $this->config->setDefaults( TemporalConfig::CONFIG, @@ -105,7 +105,7 @@ private function initConfig(EnvironmentInterface $env): void ); } - private function initWorkflowClient(TemporalConfig $config): WorkflowClientInterface + protected function initWorkflowClient(TemporalConfig $config): WorkflowClientInterface { return WorkflowClient::create( ServiceClient::create($config->getAddress()), @@ -113,7 +113,7 @@ private function initWorkflowClient(TemporalConfig $config): WorkflowClientInter ); } - private function initWorkerFactory(): WorkerFactoryInterface + protected function initWorkerFactory(): WorkerFactoryInterface { return new WorkerFactory( DataConverter::createDefault(), @@ -121,7 +121,7 @@ private function initWorkerFactory(): WorkerFactoryInterface ); } - private function initDeclarationLocator(ClassesInterface $classes): DeclarationLocatorInterface + protected function initDeclarationLocator(ClassesInterface $classes): DeclarationLocatorInterface { return new \Spiral\TemporalBridge\DeclarationLocator( $classes, @@ -129,7 +129,7 @@ private function initDeclarationLocator(ClassesInterface $classes): DeclarationL ); } - private function initWorkersRegistry( + protected function initWorkersRegistry( WorkerFactoryInterface $workerFactory, FinalizerInterface $finalizer, TemporalConfig $config