如何从独立JMS组件延续已结束的Temporal Workflow活动？

Temporal的Workflow一旦进入结束状态（Completed/Failed等），就无法再添加或执行新的Activity。所以你的核心问题需要从修改Workflow生命周期设计入手，让原Workflow在发送JMS后不立即结束，而是等待外部触发信号，再继续执行后续步骤。

具体实现步骤 #

1. 修改原Workflow，添加等待逻辑 #

在Activity3（发送JMS）执行完成后，让Workflow暂停并等待一个自定义Signal，同时将当前Workflow的ID通过JMS消息传递给消费者，方便后续定位实例。

Java示例代码：

public class MyWorkflowImpl implements MyWorkflow {
    private String jmsProcessingResult;

    @Override
    public void runWorkflow() {
        // 执行前置Activity
        activity1.execute();
        activity2.execute();
        
        // 获取当前Workflow ID，随JMS消息发送
        String workflowId = Workflow.getWorkflowInfo().getWorkflowId();
        activity3.sendJmsMessage(workflowId);
        
        // 暂停Workflow，等待JMS处理完成的Signal
        Workflow.await(() -> jmsProcessingResult != null);
        
        // 执行后续Activity
        activity4.execute(jmsProcessingResult);
        activity5.execute();
    }

    // 定义接收Signal的方法，用于触发后续流程
    @SignalMethod
    public void onJmsProcessingCompleted(String result) {
        this.jmsProcessingResult = result;
    }
}

2. 在JMS监听器中触发Signal并执行Activity #

JMS消费者收到消息后，先提取消息中的Workflow ID，执行Activity4和5，再通过Temporal的WorkflowClient向对应的Workflow实例发送Signal，唤醒Workflow完成后续逻辑（或直接由Workflow触发Activity4/5，根据你的部署需求选择）。

Java示例JMS监听器代码：

@Component
public class JmsMessageListener {
    private final WorkflowClient workflowClient;
    // 配置Activity执行参数
    private final ActivityOptions activityOptions = ActivityOptions.newBuilder()
            .setStartToCloseTimeout(Duration.ofMinutes(5))
            .build();
    // 初始化Activity Stub
    private final Activity4 activity4 = Workflow.newActivityStub(Activity4.class, activityOptions);
    private final Activity5 activity5 = Workflow.newActivityStub(Activity5.class, activityOptions);

    public JmsMessageListener(WorkflowClient workflowClient) {
        this.workflowClient = workflowClient;
    }

    @JmsListener(destination = "your-jms-queue")
    public void onMessage(Message message) throws JMSException {
        // 从JMS消息中取出Workflow ID
        String workflowId = message.getStringProperty("workflowId");
        
        // 按顺序执行Activity4和5（单消费者保证顺序）
        String processingResult = activity4.execute();
        activity5.execute();
        
        // 向目标Workflow发送Signal，唤醒后续流程
        MyWorkflow workflowStub = workflowClient.newWorkflowStub(MyWorkflow.class, workflowId);
        WorkflowClient.start(workflowStub::onJmsProcessingCompleted, processingResult);
    }
}

3. 关键配置与注意事项 #

• 确保JMS消费者所在的组件配置了Temporal WorkflowClient，连接到与原Workflow相同的Temporal集群，并且注册了Activity4和5的实现类（如果由该组件的Worker执行）。
• 你的单JMS消费者配置已经满足“按消息接收顺序逐个处理”的需求，无需额外调整。
• 如果希望Activity4和5由原Workflow的Worker执行，可将Activity调用逻辑移回Workflow的runWorkflow方法中，JMS监听器仅负责发送Signal即可。

内容的提问来源于stack exchange，提问作者Shivam Lal