func newWorkflowTaskHandler(
	domain string,
	params workerExecutionParameters,
	ppMgr pressurePointMgr,
	registry *registry,
) WorkflowTaskHandler {
	ensureRequiredParams(&params)
	return &workflowTaskHandlerImpl{
		domain:                         domain,
		logger:                         params.Logger,
		ppMgr:                          ppMgr,
		metricsScope:                   metrics.NewTaggedScope(params.MetricsScope),
		identity:                       params.Identity,
		enableLoggingInReplay:          params.EnableLoggingInReplay,
		disableStickyExecution:         params.DisableStickyExecution,
		registry:                       registry,
		nonDeterministicWorkflowPolicy: params.NonDeterministicWorkflowPolicy,
		dataConverter:                  params.DataConverter,
		contextPropagators:             params.ContextPropagators,
		tracer:                         params.Tracer,
		workflowInterceptors:           params.WorkflowInterceptors,
	}
}
// newWorkflowTaskHandler returns an implementation of workflow task handler.
newWorkflowTaskHandler returns an implementation of workflow task handler.
// newWorkflowTaskHandler returns an implementation of workflow task handler .
func newWorkflowTaskHandler(
	domain string,
	params workerExecutionParameters,
	ppMgr pressurePointMgr,
	registry *registry,
) WorkflowTaskHandler {
	ensureRequiredParams(&params)
	return &workflowTaskHandlerImpl{
		domain:                         domain,
		logger:                         params.Logger,
		ppMgr:                          ppMgr,
		metricsScope:                   metrics.NewTaggedScope(params.MetricsScope),
		identity:                       params.Identity,
		enableLoggingInReplay:          params.EnableLoggingInReplay,
		disableStickyExecution:         params.DisableStickyExecution,
		registry:                       registry,
		nonDeterministicWorkflowPolicy: params.NonDeterministicWorkflowPolicy,
		dataConverter:                  params.DataConverter,
		contextPropagators:             params.ContextPropagators,
		tracer:                         params.Tracer,
		workflowInterceptors:           params.WorkflowInterceptors,
	}
}
func newWorkflowTaskHandler ( domain string , params workerExecutionParameters , ppMgr pressurePointMgr , registry * registry , ) WorkflowTaskHandler { ensureRequiredParams ( & params ) return & workflowTaskHandlerImpl { domain : domain , logger : params . Logger , ppMgr : ppMgr , metricsScope : metrics . NewTaggedScope ( params . MetricsScope ) , identity : params . Identity , enableLoggingInReplay : params . EnableLoggingInReplay , disableStickyExecution : params . DisableStickyExecution , registry : registry , nonDeterministicWorkflowPolicy : params . NonDeterministicWorkflowPolicy , dataConverter : params . DataConverter , contextPropagators : params . ContextPropagators , tracer : params . Tracer , workflowInterceptors : params . WorkflowInterceptors , } }
newWorkflowTaskHandler returns an implementation of workflow task handler.
newWorkflowTaskHandler returns an implementation of workflow task handler .