Class QueryReplayHelper

java.lang.Object

io.temporal.internal.worker.QueryReplayHelper

public class QueryReplayHelper
extends Object

Encapsulates a special query implementation for replaying workflow histories to support Worker.replayWorkflowExecution(io.temporal.internal.common.WorkflowExecutionHistory)

The implementation in this class doesn't execute under runId lock used in the main code path of Worker, so it shouldn't be using the workflow cache either.

Constructor Summary

Constructors

Constructor	Description
QueryReplayHelper(WorkflowTaskHandler nonStickyHandler)

Method Summary

Modifier and Type	Method	Description
Optional<io.temporal.api.common.v1.Payloads>	queryWorkflowExecution(WorkflowExecutionHistory history, String queryType, Optional<io.temporal.api.common.v1.Payloads> args)
Optional<io.temporal.api.common.v1.Payloads>	queryWorkflowExecution(String jsonSerializedHistory, String queryType, Optional<io.temporal.api.common.v1.Payloads> args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryReplayHelper

public QueryReplayHelper(WorkflowTaskHandler nonStickyHandler)

Parameters:

nonStickyHandler - it's important for this handler to be non-sticky. Otherwise, we will be working with workflow cache without obtaining a runId lock.

Method Details

queryWorkflowExecution

public Optional<io.temporal.api.common.v1.Payloads> queryWorkflowExecution(String jsonSerializedHistory,
 String queryType,
 Optional<io.temporal.api.common.v1.Payloads> args)
                                                                    throws Exception

Throws:

Exception

queryWorkflowExecution

public Optional<io.temporal.api.common.v1.Payloads> queryWorkflowExecution(WorkflowExecutionHistory history,
 String queryType,
 Optional<io.temporal.api.common.v1.Payloads> args)
                                                                    throws Exception

Throws:

Exception