41
chasmEngine chasm.Engine,
42
clientBean client.Bean,
44
>
return &outboundQueueStandbyTaskExecutor{
45
>
stateMachineEnvironment: stateMachineEnvironment{
46
>
shardContext: shardCtx,
47
>
cache: workflowCache,
48
>
logger: logger,
49
>
metricsHandler: metricsHandler.WithTags(
50
>
metrics.OperationTag(metrics.OperationOutboundQueueProcessorScope),
51
>
),
52
>
},
53
>
config: shardCtx.GetConfig(),
54
>
clusterName: clusterName,
55
>
chasmEngine: chasmEngine,
56
>
clientBean: clientBean,
57
>
}
58
>
}
59
60
func (e *outboundQueueStandbyTaskExecutor) Execute(