Documentation

WorkerFactory

in package

• Application

implements WorkerFactoryInterface, LoopInterface uses EventEmitterTrait

WorkerFactory is primary entry point for the temporal application. This class is responsible for the communication with parent RoadRunner process and can be used to create taskQueue workflow and activity workers.

$factory = WorkerFactory::create();

$worker = $factory->newWorker('default');

$worker->registerWorkflowTypes(WorkflowType::class);
$worker->registerActivityImplementations(new MyActivityImplementation());

Table of Contents

Interfaces

WorkerFactoryInterface

The interface is responsible for providing an interface for registering all dependencies and creating a global event loop.

LoopInterface

The interface is responsible for providing an interface for creating an event loop.

Constants

ERROR_HEADER_NOT_STRING_TYPE  = 'Header "%s" argument type must be a string, but %s given'

ERROR_HEADERS_TYPE  = 'Received headers type must be a string, but %s given'

ERROR_MESSAGE_TYPE  = 'Received message type must be a string, but %s given'

ERROR_QUEUE_NOT_FOUND  = 'Cannot find a worker for task queue "%s"'

HEADER_TASK_QUEUE  = 'taskQueue'

Properties

$client  : ClientInterface

$codec  : CodecInterface

$converter  : DataConverterInterface

$env  : EnvironmentInterface

$marshaller  : MarshallerInterface<string|int, array<string|int, mixed>>

$queues  : RepositoryInterface<string|int, WorkerInterface>

$reader  : ReaderInterface

$responses  : QueueInterface

$router  : RouterInterface

$rpc  : RPCConnectionInterface

$server  : ServerInterface

Methods

__construct()  : mixed

create()  : WorkerFactoryInterface

getClient()  : ClientInterface

getDataConverter()  : DataConverterInterface

getEnvironment()  : EnvironmentInterface

getMarshaller()  : MarshallerInterface<string|int, array<string|int, mixed>>

getQueue()  : QueueInterface

getReader()  : ReaderInterface

newWorker()  : WorkerInterface

Create a new Temporal Worker with the name of the task queue and register in worker.

run()  : int

Start processing workflows and activities processing.

tick()  : void

createClient()  : ClientInterface

createMarshaller()  : MarshallerInterface<string|int, array<string|int, mixed>>

createQueue()  : QueueInterface

createReader()  : ReaderInterface

createRouter()  : RouterInterface

createServer()  : ServerInterface

createTaskQueue()  : RepositoryInterface<string|int, WorkerInterface>

boot()  : void

createCodec()  : CodecInterface

dispatch()  : string

findTaskQueueNameOrFail()  : string

findTaskQueueOrFail()  : WorkerInterface

onRequest()  : PromiseInterface