活动的单独任务列表 - AWS SWF

Question

我有一个用例，我希望系统中有 10 个工作线程。其中，6 个工作线程应该轮询一个任务列表，4 个工作线程应该轮询另一个任务列表。

我在 Flow Framework 上以这种方式配置了我的代码。

我的一项活动已注册到不同的任务列表。所有其他活动到默认任务列表。我有 6 个工作线程正在侦听默认任务列表，其余四个正在侦听其他任务列表。

但是当我执行我的工作流程时，我得到了错误：

任务列表名称：CIMSProposalActivityValidationTList

身份：29547@ccs-master-1001.vdc.xyz.com

详细信息：["java.lang.IllegalStateException",{"cause":null,"stackTrace":[{"methodName":"current","fileName":"AsyncContextBase.java ","lineNumber":27,"className":"com.amazonaws.services.simpleworkflow.flow.core.AsyncContextBase","nativeMethod":false},{"methodName":"","fileName":"AsyncContextBase. java","lineNumber":49,"className":"com.amazonaws.services.simpleworkflow.flow.core.AsyncContextBase","nativeMethod":false},{"methodName":"","fileName":"TryCatchFinallyContext .java","lineNumber":46,"className":"com.amazonaws.services.simpleworkflow.flow.core.TryCatchFinallyContext","nativeMethod":false},{"methodName":"","fileName":" TryCatchFinally.java","lineNumber":233,"className":"com.amazonaws.services.simpleworkflow.flow.core.TryCatchFinally","nativeMethod":false},{"methodName":"","fileName": "TryCatch.java","lineNumber":22,"className":"com.amazonaws.services.simpleworkflow.flow.core.TryCatch","nativeMethod":false},{"methodName":"","fileName" :"GrooveScheduleAspect.java","lin eNumber":93,"className":"com.amazon.transportation.groove.aspectj.GrooveScheduleAspect$1","nativeMethod":false},{"methodName":"processGrooveSchedule","fileName":"GrooveScheduleAspect.java", "lineNumber":93,"className":"com.amazon.transportation.groove.aspectj.GrooveScheduleAspect","nativeMethod":false},{"methodName":"validate","fileName":"ValidationActivitiesImpl.java", "lineNumber":23,"className":"com.amazon.cimsworkflow.activities.impl.ValidationActivitiesImpl","nativeMethod":false},{"methodName":"invoke0","fileName":"NativeMethodAccessorImpl.java", "lineNumber":-2,"className":"sun.reflect.NativeMethodAccessorImpl","nativeMethod":true},{"methodName":"invoke","fileName":"NativeMethodAccessorImpl.java","lineNumber":57 ,"className":"sun.reflect.NativeMethodAccessorImpl","nativeMethod":false},{"methodName":"invoke","fileName":"DelegatingMethodAccessorImpl.java","lineNumber":43,"className":" sun.reflect.DelegatingMethodAccessorImpl","nativeMethod":false},{"methodName":"invoke","fileName":"Meth od.java","lineNumber":606,"className":"java.lang.reflect.Method","nativeMethod":false},{"methodName":"execute","fileName":"POJOActivityImplementation.java" ,"lineNumber":63,"className":"com.amazonaws.services.simpleworkflow.flow.pojo.POJOActivityImplementation","nativeMethod":false},{"methodName":"execute","fileName":"ActivityImplementationBase. java","lineNumber":46,"className":"com.amazonaws.services.simpleworkflow.flow.generic.ActivityImplementationBase","nativeMethod":false},{"methodName":"execute","fileName":" SynchronousActivityTaskPoller.java","lineNumber":196,"className":"com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller","nativeMethod":false},{"methodName":"run","fileName" :"ActivityTaskPoller.java","lineNumber":97,"className":"com.amazonaws.services.simpleworkflow.flow.worker.ActivityTaskPoller$1","nativeMethod":false},{"methodName":"runWorker", "fileName":"ThreadPoolExecutor.java","lineNumber":1145,"className":"java.util.concurrent.ThreadPoolExecutor ","nativeMethod":false},{"methodName":"run","fileName":"ThreadPoolExecutor.java","lineNumber":615,"className":"java.util.concurrent.ThreadPoolExecutor$Worker", "nativeMethod":false},{"methodName":"run","fileName":"Thread.java","lineNumber":744,"className":"java.lang.Thread","nativeMethod":false} ],"消息":"尝试 在 AsyncScope.doAsync() 之外执行异步代码 method","localizedMessage":"尝试执行异步代码 在 AsyncScope.doAsync() 之外 方法","抑制":["[Ljava.lang.Throwable;",[]]}]

原因：

• 尝试在 AsyncScope.doAsync() 方法之外执行异步代码

我的任务列表是我创建的新列表。线程也符合预期。但我收到了这个错误。有关如何解决此问题的任何线索。请回复

Answer 1

AWS Flow Framework 活动实施不能包含任何异步代码。所有此类代码仅在工作流实现中允许使用。从堆栈跟踪来看，您的活动实现确实引用了 TryCatch 类，该类只能用于异步错误处理。

Answer 2

不同的活动不能有相同的任务列表名称。每个活动需要不同的任务列表名称。 如果您希望同一活动轮询多个任务列表，则运行同一活动的多个实例并使每个实例轮询不同的任务列表。