diff --git a/src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java b/src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java index c9c3ef81d..5c6722b7c 100644 --- a/src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java +++ b/src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java @@ -22,7 +22,6 @@ import com.uber.cadence.GetTaskListsByDomainRequest; import com.uber.cadence.GetTaskListsByDomainResponse; import com.uber.cadence.activity.ActivityOptions; -import com.uber.cadence.activity.LocalActivityOptions; import com.uber.cadence.internal.metrics.NoopScope; import com.uber.cadence.internal.worker.ActivityTaskHandler; import com.uber.cadence.internal.worker.ActivityTaskHandler.Result; @@ -31,26 +30,19 @@ import com.uber.cadence.testing.TestActivityEnvironment; import com.uber.cadence.testing.TestEnvironmentOptions; import com.uber.cadence.workflow.*; -import com.uber.cadence.workflow.Functions.Func; -import com.uber.cadence.workflow.Functions.Func1; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Proxy; import java.lang.reflect.Type; import java.nio.charset.StandardCharsets; import java.time.Duration; -import java.util.Map; import java.util.Objects; -import java.util.Optional; -import java.util.Random; import java.util.UUID; import java.util.concurrent.CancellationException; import java.util.concurrent.CompletableFuture; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.atomic.AtomicInteger; -import java.util.function.BiPredicate; import java.util.function.Consumer; -import java.util.function.Supplier; import org.apache.thrift.TException; import org.apache.thrift.async.AsyncMethodCallback; @@ -164,105 +156,6 @@ public Promise executeActivity( return Workflow.newPromise(getReply(task, taskResult, resultClass, resultType)); } - @Override - public Promise executeLocalActivity( - String activityName, - Class resultClass, - Type resultType, - Object[] args, - LocalActivityOptions options) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public WorkflowResult executeChildWorkflow( - String workflowType, - Class resultClass, - Type resultType, - Object[] args, - ChildWorkflowOptions options) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public Random newRandom() { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public Promise signalExternalWorkflow( - String domain, WorkflowExecution execution, String signalName, Object[] args) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public Promise signalExternalWorkflow( - WorkflowExecution execution, String signalName, Object[] args) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public Promise cancelWorkflow(WorkflowExecution execution) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public void sleep(Duration duration) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public boolean await(Duration timeout, String reason, Supplier unblockCondition) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public void await(String reason, Supplier unblockCondition) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public Promise newTimer(Duration duration) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public R sideEffect(Class resultClass, Type resultType, Func func) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public R mutableSideEffect( - String id, Class resultClass, Type resultType, BiPredicate updated, Func func) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public int getVersion(String changeID, int minSupported, int maxSupported) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public void continueAsNew( - Optional workflowType, Optional options, Object[] args) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public void registerQuery(String queryType, Type[] argTypes, Func1 callback) { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public UUID randomUUID() { - throw new UnsupportedOperationException("not implemented"); - } - - @Override - public void upsertSearchAttributes(Map searchAttributes) { - throw new UnsupportedOperationException("not implemented"); - } - private T getReply( PollForActivityTaskResponse task, ActivityTaskHandler.Result response,