NorthboundRunTest.java 文件源码

@Then("^status of flow (.*) could be read$")
public void checkFlowStatus(final String flowId) throws Exception {
    String flowName = FlowUtils.getFlowName(flowId);
    FlowIdStatusPayload payload = getFlowState(flowName, expectedFlowStatus);

    assertNotNull(payload);

    assertEquals(flowName, payload.getId());
    assertEquals(expectedFlowStatus, payload.getStatus());
}