TutorialWorker.java

package io.temporal.learning;
import io.temporal.worker.*;
import io.temporal.client.WorkflowClient;
import io.temporal.serviceclient.WorkflowServiceStubs;

public class TutorialWorker {
    public static void runTutorialWorker(String[] args) {
        // Create a service stub
        WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
        
        // A Workflow Client can start, Signal, and Query a Workflow Execution
        WorkflowClient client = WorkflowClient.newInstance(service);
        
        // A Workflow Factory creates workers.
        WorkerFactory factory = WorkerFactory.newInstance(client);
        
        // A Worker listens to one task queue, processing workflows and activities.
        Worker worker = factory.newWorker("TutorialWorkflow-queue");

        // Register a Workflow implementation with this worker.
        // The implementation must be known at runtime to dispatch workflow tasks.
        worker.registerWorkflowImplementationTypes(TutorialWorkflow.TutorialWorkflowImpl.class);
        
        // Register Activity Types from the Activity vendor with the worker.
        // Each activity is stateless and thread-safe, so use a single shared instance.
        worker.registerActivitiesImplementations(new TutorialActivities.TutorialActivitiesImpl());
        
        // Start all registered workers. The workers will start polling.
        factory.start();
    }
}