Amazon SWF @Signal

Question

有没有办法从Amazon SWF工作流的活动中调用@Signal函数。我希望能够通知工作流一些处理已经完成，并且它应该为该处理的子集派生一个子工作流。如何做到这一点？

Answer 1

这听起来像是您想告诉工作流某个部分的活动已经完成，但是您想继续运行当前的活动。如果是这种情况，那么我建议你将你的活动分成两部分，并使用第一部分的结果来告知是否需要派生子工作流。我不认为在流程框架中在活动中间向工作流发送信号是可能的。但是您可以使用原始SWF API来发送信号(在这种情况下，您需要将"Run ID“作为参数之一传递给您的activity )。

Answer 2

生成的工作流外部客户端应用于从活动代码中发送信号。ActivityExecutionContext包含初始化它所需的所有数据：

public class MyActivitiesImpl implements MyActivities {

    private final ActivityExecutionContextProvider contextProvider = new ActivityExecutionContextProviderImpl();

    public void sendSignalBackActivity() {
        ActivityExecutionContext context = contextProvider.getActivityExecutionContext();
        AmazonSimpleWorkflow service = context.getService();
        String domain = context.getDomain();
        WorkflowExecution workflowExecution = context.getWorkflowExecution();
        MyWorkflowClientExternalFactory factory = new MyWorkflowClientExternalFactoryImpl(service, domain);
        GreeterClientExternal workflow = factory.getClient(workflowExecution);
        workflow.signalMethod();
    }
}

当外部客户端调用SignalWorkflowExecution SWF API时，它可能会由于间歇性连接问题而失败。因此，activity实现可能决定捕获并处理(可能通过重试)在这种情况下抛出的AmazonServiceException。