Interface ManualActivityCompletionClientFactory

public interface ManualActivityCompletionClientFactory

Method Summary

Modifier and Type	Method	Description
ManualActivityCompletionClient	getClient(byte[] taskToken, com.uber.m3.tally.Scope metricsScope)
ManualActivityCompletionClient	getClient(byte[] taskToken, com.uber.m3.tally.Scope metricsScope, ActivitySerializationContext activitySerializationContext)
ManualActivityCompletionClient	getClient(io.temporal.api.common.v1.WorkflowExecution execution, String activityId, com.uber.m3.tally.Scope metricsScope)
ManualActivityCompletionClient	getClient(io.temporal.api.common.v1.WorkflowExecution execution, String activityId, com.uber.m3.tally.Scope metricsScope, ActivitySerializationContext activitySerializationContext)
static ManualActivityCompletionClientFactory	newFactory(io.temporal.serviceclient.WorkflowServiceStubs service, String namespace, String identity, DataConverter dataConverter)	Create a ManualActivityCompletionClientFactory that emits simple ManualActivityCompletionClientImpl implementations

Method Details

newFactory

static ManualActivityCompletionClientFactory newFactory(@Nonnull
 io.temporal.serviceclient.WorkflowServiceStubs service,
 @Nonnull
 String namespace,
 @Nonnull
 String identity,
 @Nonnull
 DataConverter dataConverter)

Create a ManualActivityCompletionClientFactory that emits simple ManualActivityCompletionClientImpl implementations

getClient

ManualActivityCompletionClient getClient(@Nonnull
 byte[] taskToken,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 byte[] taskToken,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nullable
 ActivitySerializationContext activitySerializationContext)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 io.temporal.api.common.v1.WorkflowExecution execution,
 @Nonnull
 String activityId,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope)

getClient

ManualActivityCompletionClient getClient(@Nonnull
 io.temporal.api.common.v1.WorkflowExecution execution,
 @Nonnull
 String activityId,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nullable
 ActivitySerializationContext activitySerializationContext)