package Ġse b . temporal . test . flows . exec Ċ Ċ import Ġio . temporal . client . Workflow Client Ċ import Ġio . temporal . worker . Worker Factory ĊĊ Ċ class ĠExecution Worker ( private Ġval Ġexecution Activity : ĠExecution Activity , Ġprivate Ġval Ġworkflow Client : ĠWorkflow Client ) Ġ{ ĊĊĠĠĠ Ġ// ĠWorker Ġfactory Ġis Ġused Ġto Ġcreate ĠWork ers Ġthat Ġpoll Ġspecific ĠTask ĠQue ues . ĊĠĠĠ Ġval Ġfactory Ġ= ĠWorker Factory . newInstance ( workflow Client ) ĊĠĠĠ Ġval Ġworker Ġ= Ġfactory . new Worker ( Execution Workflow Impl . queue Name ) ĊĊĠĠĠ Ġ// ĠThis ĠWorker Ġhosts Ġboth ĠWorkflow Ġand ĠActivity Ġimplementations . ĊĠĠĠ Ġ// ĠWorkflow s Ġare Ġstate ful Ġso Ġa Ġtype Ġis Ġneeded Ġto Ġcreate Ġinstances . ĊĠĠĠ Ġfun Ġstart () Ġ{ ĊĠĠĠĠĠĠĠ Ġworker . register Workflow Implementation Types ( Execution Workflow Impl :: class . java ) ĊĠĠĠĠĠĠĠ Ġ// ĠActiv ities Ġare Ġstate less Ġand Ġthread Ġsafe Ġso Ġa Ġshared Ġinstance Ġis Ġused . ĊĠĠĠĠĠĠĠ Ġworker . register Activities Implement ations ( execution Activity ) ĊĠĠĠĠĠĠĠ Ġ// ĠStart Ġlistening Ġto Ġthe ĠTask ĠQueue . ĊĠĠĠĠĠĠĠ Ġfactory . start () ĊĠĠĠ Ġ} Ċ Ċ }